Skip to content

Commit 7e7fd7b

Browse files
committed
[hotfix][batch] Fix incorrectly use of ExecutionMode in AdaptiveBatchSchedulerFactory
1 parent 483a94a commit 7e7fd7b

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptivebatch/AdaptiveBatchSchedulerFactory.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@
2222
import org.apache.flink.annotation.VisibleForTesting;
2323
import org.apache.flink.api.common.BatchShuffleMode;
2424
import org.apache.flink.api.common.ExecutionConfig;
25-
import org.apache.flink.api.common.ExecutionMode;
25+
import org.apache.flink.api.common.RuntimeExecutionMode;
2626
import org.apache.flink.configuration.BatchExecutionOptions;
2727
import org.apache.flink.configuration.Configuration;
2828
import org.apache.flink.configuration.ExecutionOptions;
@@ -367,12 +367,12 @@ private static void checkAllExchangesAreSupported(final JobGraph jobGraph) {
367367
+ "to be executed with types of all edges being BLOCKING or HYBRID_FULL/HYBRID_SELECTIVE. "
368368
+ "To do that, you need to configure '%s' to '%s' or '%s/%s'. "
369369
+ "Note that for DataSet jobs which do not recognize the aforementioned shuffle mode, "
370-
+ "the ExecutionMode needs to be %s to force BLOCKING shuffle",
370+
+ "the RuntimeExecutionMode needs to be %s to force BLOCKING shuffle",
371371
ExecutionOptions.BATCH_SHUFFLE_MODE.key(),
372372
BatchShuffleMode.ALL_EXCHANGES_BLOCKING,
373373
BatchShuffleMode.ALL_EXCHANGES_HYBRID_FULL,
374374
BatchShuffleMode.ALL_EXCHANGES_HYBRID_SELECTIVE,
375-
ExecutionMode.BATCH_FORCED));
375+
RuntimeExecutionMode.BATCH));
376376
}
377377
}
378378
}

0 commit comments

Comments
 (0)