[hotfix][test] Fix TypeHintITCase if adaptive scheduler enabled

silenceland · Oct 11, 2024 · d2c241a · d2c241a
1 parent 7b351fd
commit d2c241a
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/flink-tests/src/test/java/org/apache/flink/test/operators/TypeHintITCase.java b/flink-tests/src/test/java/org/apache/flink/test/operators/TypeHintITCase.java
@@ -18,6 +18,7 @@
 
 package org.apache.flink.test.operators;
 
+import org.apache.flink.api.common.RuntimeExecutionMode;
 import org.apache.flink.api.common.functions.CoGroupFunction;
 import org.apache.flink.api.common.functions.FlatJoinFunction;
 import org.apache.flink.api.common.functions.FlatMapFunction;
@@ -109,6 +110,7 @@ public void testFlatMapWithClassTypeHint() throws Exception {
     @Test
     public void testJoinWithTypeInformationTypeHint() throws Exception {
         final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
+        env.setRuntimeMode(RuntimeExecutionMode.BATCH);
 
         DataStreamSource<Tuple3<Integer, Long, String>> ds1 =
                 CollectionDataStreams.getSmall3TupleDataSet(env);
@@ -134,6 +136,7 @@ public void testJoinWithTypeInformationTypeHint() throws Exception {
     @Test
     public void testFlatJoinWithTypeInformationTypeHint() throws Exception {
         final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
+        env.setRuntimeMode(RuntimeExecutionMode.BATCH);
 
         DataStreamSource<Tuple3<Integer, Long, String>> ds1 =
                 CollectionDataStreams.getSmall3TupleDataSet(env);
@@ -159,6 +162,7 @@ public void testFlatJoinWithTypeInformationTypeHint() throws Exception {
     @Test
     public void testCoGroupWithTypeInformationTypeHint() throws Exception {
         final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
+        env.setRuntimeMode(RuntimeExecutionMode.BATCH);
 
         DataStreamSource<Tuple3<Integer, Long, String>> ds1 =
                 CollectionDataStreams.getSmall3TupleDataSet(env);