You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2017/09/07 19:14:52 UTC
[11/18] storm git commit: Added in max spout pending detection
Added in max spout pending detection
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/0ef492e7
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/0ef492e7
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/0ef492e7
Branch: refs/heads/master
Commit: 0ef492e7e7189fe13bef067b3892bbd1be7457a0
Parents: a4c372c
Author: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Authored: Thu Aug 24 17:36:22 2017 -0500
Committer: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Committed: Thu Aug 24 17:36:22 2017 -0500
----------------------------------------------------------------------
.../java/org/apache/storm/loadgen/LoadMetricsServer.java | 9 +++++++++
1 file changed, 9 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/0ef492e7/examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/LoadMetricsServer.java
----------------------------------------------------------------------
diff --git a/examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/LoadMetricsServer.java b/examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/LoadMetricsServer.java
index 36050ae..31bea1f 100644
--- a/examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/LoadMetricsServer.java
+++ b/examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/LoadMetricsServer.java
@@ -972,6 +972,15 @@ public class LoadMetricsServer extends HttpForwardingMetricsServer {
"receive " + pop + "/" + cap);
}
}
+ } else if (dp.name.equals("__skipped-max-spout-ms")) {
+ if (dp.value instanceof Number) {
+ double full = ((Number) dp.value).doubleValue() / 10_000.0; //The frequency of reporting
+ if (full >= 0.8) {
+ congested.get().put(
+ topologyId + ":" + taskInfo.srcComponentId + ":" + taskInfo.srcTaskId,
+ "max.spout.pending " + (int)(full * 100) + "%");
+ }
+ }
}
}
}