Run ci with jdk17.

lvyanquan · lvyanquan · commit 48a5af1b99a1 · 2025-12-24T14:31:54.000+08:00
diff --git a/flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/utils/PipelineTestEnvironment.java b/flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/src/test/java/org/apache/flink/cdc/pipeline/tests/utils/PipelineTestEnvironment.java
@@ -404,7 +404,10 @@ public void waitUntilJobState(Duration timeout, JobStatus expectedStatus) {
     }
 
     protected String getFlinkDockerImageTag() {
-        return String.format("flink:%s-scala_2.12", flinkVersion);
+        if (System.getProperty("java.specification.version").equals("17")) {
+            return String.format("flink:%s-scala_2.12-java17", flinkVersion);
+        }
+        return String.format("flink:%s-scala_2.12-java11", flinkVersion);
     }
 
     private ExecResult executeAndCheck(GenericContainer<?> container, String... command) {

Original file line number	Diff line number	Diff line change
`@@ -404,7 +404,10 @@ public void waitUntilJobState(Duration timeout, JobStatus expectedStatus) {`
`404`	`404`	`}`
`405`	`405`
`406`	`406`	`protected String getFlinkDockerImageTag() {`
`407`		`- return String.format("flink:%s-scala_2.12", flinkVersion);`
	`407`	`+ if (System.getProperty("java.specification.version").equals("17")) {`
	`408`	`+ return String.format("flink:%s-scala_2.12-java17", flinkVersion);`
	`409`	`+ }`
	`410`	`+ return String.format("flink:%s-scala_2.12-java11", flinkVersion);`
`408`	`411`	`}`
`409`	`412`
`410`	`413`	`private ExecResult executeAndCheck(GenericContainer<?> container, String... command) {`