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())