[INLONG-9402][Sort] Change the flink docker java version from 11 to 8.

apache · Apr 8, 2024 · 33b8695 · 33b8695
1 parent da856a4
commit 33b8695
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...d-tests-v1.15/src/test/java/org/apache/inlong/sort/tests/utils/FlinkContainerTestEnv.java b/...d-tests-v1.15/src/test/java/org/apache/inlong/sort/tests/utils/FlinkContainerTestEnv.java
@@ -111,7 +111,7 @@ public abstract class FlinkContainerTestEnv extends TestLogger {
     public static void before() {
         LOG.info("Starting containers...");
         jobManager =
-                new GenericContainer<>("flink:1.15.4-scala_2.12")
+                new GenericContainer<>("flink:1.15.4-scala_2.12-java8")
                         .withCommand("jobmanager")
                         .withNetwork(NETWORK)
                         .withNetworkAliases(INTER_CONTAINER_JM_ALIAS)
@@ -120,7 +120,7 @@ public static void before() {
                         .withExposedPorts(JOB_MANAGER_REST_PORT)
                         .withLogConsumer(new Slf4jLogConsumer(JM_LOG));
         taskManager =
-                new GenericContainer<>("flink:1.15.4-scala_2.12")
+                new GenericContainer<>("flink:1.15.4-scala_2.12-java8")
                         .withCommand("taskmanager")
                         .withNetwork(NETWORK)
                         .withNetworkAliases(INTER_CONTAINER_TM_ALIAS)