You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@heron.apache.org by hu...@apache.org on 2018/08/21 20:48:34 UTC

[incubator-heron] branch huijunw/fix2980 updated: mergelog

This is an automated email from the ASF dual-hosted git repository.

huijun pushed a commit to branch huijunw/fix2980
in repository https://gitbox.apache.org/repos/asf/incubator-heron.git


The following commit(s) were added to refs/heads/huijunw/fix2980 by this push:
     new c8d59bb  mergelog
c8d59bb is described below

commit c8d59bbfa9f0bbb180fe5488758585970f4e7e90
Author: Huijun Wu <hu...@twitter.com>
AuthorDate: Tue Aug 21 13:48:15 2018 -0700

    mergelog
---
 .../src/java/org/apache/heron/scheduler/RuntimeManagerRunner.java   | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/heron/scheduler-core/src/java/org/apache/heron/scheduler/RuntimeManagerRunner.java b/heron/scheduler-core/src/java/org/apache/heron/scheduler/RuntimeManagerRunner.java
index 2166bcd..38c4a94 100644
--- a/heron/scheduler-core/src/java/org/apache/heron/scheduler/RuntimeManagerRunner.java
+++ b/heron/scheduler-core/src/java/org/apache/heron/scheduler/RuntimeManagerRunner.java
@@ -195,11 +195,11 @@ public class RuntimeManagerRunner {
       throws TopologyRuntimeManagementException, PackingException, UpdateDryRunResponse {
     assert !potentialStaleExecutionData;
     String newParallelism = updateConfig.getStringValue(RUNTIME_MANAGER_COMPONENT_PARALLELISM_KEY);
-    LOG.info("newParallelism " + newParallelism);
     String newContainerNumber = updateConfig.getStringValue(RUNTIME_MANAGER_CONTAINER_NUMBER_KEY);
-    LOG.info("newContainerNumber " + newContainerNumber);
     String userRuntimeConfig = updateConfig.getStringValue(RUNTIME_MANAGER_RUNTIME_CONFIG_KEY);
-    LOG.info("userRuntimeConfig " + userRuntimeConfig);
+    LOG.info("userRuntimeConfig " + userRuntimeConfig
+        + "; newParallelism " + newParallelism
+        + "; newContainerNumber " + newContainerNumber);
 
     // parallelism and runtime config can not be updated at the same time.
     if (((newParallelism != null && !newParallelism.isEmpty())