From e2486188610ca30f0f26c0c0f061d3349a5dc6f3 Mon Sep 17 00:00:00 2001 From: Maximilian Michels Date: Thu, 10 Dec 2015 16:04:31 +0100 Subject: [PATCH] [hotfix] respect default local number of task managers --- .../apache/flink/runtime/executiongraph/ExecutionGraph.java | 2 +- .../flink/runtime/minicluster/LocalFlinkMiniCluster.scala | 6 ++++-- 2 files changed, 5 insertions(+), 3 deletions(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java index 9218fe450a5..1e3a4eb121d 100755 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java @@ -1074,7 +1074,7 @@ public class ExecutionGraph implements Serializable { LOG.warn("Received accumulator result for unknown execution {}.", execID); } } catch (Exception e) { - LOG.error("Cannot update accumulators for job " + jobID, e); + LOG.error("Cannot update accumulators for job {}.", jobID, e); } } diff --git a/flink-runtime/src/main/scala/org/apache/flink/runtime/minicluster/LocalFlinkMiniCluster.scala b/flink-runtime/src/main/scala/org/apache/flink/runtime/minicluster/LocalFlinkMiniCluster.scala index a27c840642b..913aec04a5e 100644 --- a/flink-runtime/src/main/scala/org/apache/flink/runtime/minicluster/LocalFlinkMiniCluster.scala +++ b/flink-runtime/src/main/scala/org/apache/flink/runtime/minicluster/LocalFlinkMiniCluster.scala @@ -158,7 +158,8 @@ class LocalFlinkMiniCluster( ConfigConstants.DEFAULT_TASK_MANAGER_NETWORK_NUM_BUFFERS) * bufferSize.toLong val numTaskManager = config.getInteger( - ConfigConstants.LOCAL_NUMBER_TASK_MANAGER, 1) + ConfigConstants.LOCAL_NUMBER_TASK_MANAGER, + ConfigConstants.DEFAULT_LOCAL_NUMBER_TASK_MANAGER) val memoryFraction = config.getFloat( ConfigConstants.TASK_MANAGER_MEMORY_FRACTION_KEY, @@ -184,7 +185,8 @@ class LocalFlinkMiniCluster( config.setString(ConfigConstants.JOB_MANAGER_IPC_ADDRESS_KEY, hostname) - config.setInteger(ConfigConstants.LOCAL_NUMBER_TASK_MANAGER, 1) + config.setInteger(ConfigConstants.LOCAL_NUMBER_TASK_MANAGER, + ConfigConstants.DEFAULT_LOCAL_NUMBER_TASK_MANAGER) // Reduce number of threads for local execution config.setInteger(NettyConfig.NUM_THREADS_CLIENT, 1) -- GitLab