[hotfix] respect default local number of task managers

kongxi · Dec 15, 2015 · e248618 · e248618
1 parent e20c639
commit e248618
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 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
@@ -1074,7 +1074,7 @@ public void updateAccumulators(AccumulatorSnapshot accumulatorSnapshot) {
  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/...k-runtime/src/main/scala/org/apache/flink/runtime/minicluster/LocalFlinkMiniCluster.scala b/...k-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)