fixup! [BEAM-9295] Add Flink 1.10 build target and Make FlinkRunner c…

…ompatible with Flink 1.10
apache · Feb 27, 2020 · 82b781c · 82b781c
1 parent 5999013
commit 82b781c
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkExecutionEnvironments.java b/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkExecutionEnvironments.java
@@ -67,6 +67,7 @@ static ExecutionEnvironment createBatchExecutionEnvironment(
 
     // depending on the master, create the right environment.
     if ("[local]".equals(flinkMasterHostPort)) {
+      flinkConfiguration.setString("taskmanager.memory.managed.size", "2048m");
       flinkBatchEnv = ExecutionEnvironment.createLocalEnvironment(flinkConfiguration);
     } else if ("[collection]".equals(flinkMasterHostPort)) {
       flinkBatchEnv = new CollectionEnvironment();