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/13 21:33:48 UTC
[incubator-heron] branch huijunw/refactorhealthmgr0.2.3 updated
(62b5457 -> 0625385)
This is an automated email from the ASF dual-hosted git repository.
huijun pushed a change to branch huijunw/refactorhealthmgr0.2.3
in repository https://gitbox.apache.org/repos/asf/incubator-heron.git.
from 62b5457 change log to fine, when the verbose is enabled
new b173ca3 add verbose
new 0625385 use list
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../src/java/org/apache/heron/healthmgr/sensors/BackPressureSensor.java | 2 +-
.../src/java/org/apache/heron/healthmgr/sensors/BufferSizeSensor.java | 2 +-
.../src/java/org/apache/heron/healthmgr/sensors/ExecuteCountSensor.java | 2 +-
3 files changed, 3 insertions(+), 3 deletions(-)
[incubator-heron] 02/02: use list
Posted by hu...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
huijun pushed a commit to branch huijunw/refactorhealthmgr0.2.3
in repository https://gitbox.apache.org/repos/asf/incubator-heron.git
commit 062538549a59d61ac9ef7d43f9dfa3882084b133
Author: Huijun Wu <hu...@twitter.com>
AuthorDate: Mon Aug 13 14:33:17 2018 -0700
use list
---
heron/executor/src/python/heron_executor.py | 3 +--
.../java/org/apache/heron/healthmgr/sensors/BackPressureSensor.java | 2 +-
.../src/java/org/apache/heron/healthmgr/sensors/BufferSizeSensor.java | 2 +-
.../java/org/apache/heron/healthmgr/sensors/ExecuteCountSensor.java | 2 +-
4 files changed, 4 insertions(+), 5 deletions(-)
diff --git a/heron/executor/src/python/heron_executor.py b/heron/executor/src/python/heron_executor.py
index c53a608..d62b7da 100755
--- a/heron/executor/src/python/heron_executor.py
+++ b/heron/executor/src/python/heron_executor.py
@@ -506,8 +506,7 @@ class HeronExecutor(object):
"--role", self.role,
"--environment", self.environment,
"--topology_name", self.topology_name,
- "--metricsmgr_port", self.metrics_manager_port,
- "--verbose"]
+ "--metricsmgr_port", self.metrics_manager_port]
return healthmgr_cmd
diff --git a/heron/healthmgr/src/java/org/apache/heron/healthmgr/sensors/BackPressureSensor.java b/heron/healthmgr/src/java/org/apache/heron/healthmgr/sensors/BackPressureSensor.java
index 0d94653..857b17b 100644
--- a/heron/healthmgr/src/java/org/apache/heron/healthmgr/sensors/BackPressureSensor.java
+++ b/heron/healthmgr/src/java/org/apache/heron/healthmgr/sensors/BackPressureSensor.java
@@ -70,7 +70,7 @@ public class BackPressureSensor extends BaseSensor {
Collection<Measurement> result = new ArrayList<>();
Instant now = context.checkpoint();
- Collection<String> boltComponents = physicalPlanProvider.getBoltNames();
+ List<String> boltComponents = physicalPlanProvider.getBoltNames();
Duration duration = getDuration();
for (String component : boltComponents) {
String[] boltInstanceNames = packingPlanProvider.getBoltInstanceNames(component);
diff --git a/heron/healthmgr/src/java/org/apache/heron/healthmgr/sensors/BufferSizeSensor.java b/heron/healthmgr/src/java/org/apache/heron/healthmgr/sensors/BufferSizeSensor.java
index b407cce..9ed271a 100644
--- a/heron/healthmgr/src/java/org/apache/heron/healthmgr/sensors/BufferSizeSensor.java
+++ b/heron/healthmgr/src/java/org/apache/heron/healthmgr/sensors/BufferSizeSensor.java
@@ -62,7 +62,7 @@ public class BufferSizeSensor extends BaseSensor {
Collection<Measurement> result = new ArrayList<>();
Instant now = context.checkpoint();
- Collection<String> boltComponents = physicalPlanProvider.getBoltNames();
+ List<String> boltComponents = physicalPlanProvider.getBoltNames();
Duration duration = getDuration();
for (String component : boltComponents) {
diff --git a/heron/healthmgr/src/java/org/apache/heron/healthmgr/sensors/ExecuteCountSensor.java b/heron/healthmgr/src/java/org/apache/heron/healthmgr/sensors/ExecuteCountSensor.java
index 94fd48a..d38df4c 100644
--- a/heron/healthmgr/src/java/org/apache/heron/healthmgr/sensors/ExecuteCountSensor.java
+++ b/heron/healthmgr/src/java/org/apache/heron/healthmgr/sensors/ExecuteCountSensor.java
@@ -50,7 +50,7 @@ public class ExecuteCountSensor extends BaseSensor {
@Override
public Collection<Measurement> fetch() {
- Collection<String> bolts = physicalPlanProvider.getBoltNames();
+ List<String> bolts = physicalPlanProvider.getBoltNames();
now = context.checkpoint();
return metricsProvider.getMeasurements(now, getDuration(), getMetricTypes(), bolts);
}
[incubator-heron] 01/02: add verbose
Posted by hu...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
huijun pushed a commit to branch huijunw/refactorhealthmgr0.2.3
in repository https://gitbox.apache.org/repos/asf/incubator-heron.git
commit b173ca305b10a5abeb5daf16fca555e30eb1df48
Author: Huijun Wu <hu...@twitter.com>
AuthorDate: Mon Aug 13 14:12:53 2018 -0700
add verbose
---
heron/executor/src/python/heron_executor.py | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/heron/executor/src/python/heron_executor.py b/heron/executor/src/python/heron_executor.py
index d62b7da..c53a608 100755
--- a/heron/executor/src/python/heron_executor.py
+++ b/heron/executor/src/python/heron_executor.py
@@ -506,7 +506,8 @@ class HeronExecutor(object):
"--role", self.role,
"--environment", self.environment,
"--topology_name", self.topology_name,
- "--metricsmgr_port", self.metrics_manager_port]
+ "--metricsmgr_port", self.metrics_manager_port,
+ "--verbose"]
return healthmgr_cmd