You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pt...@apache.org on 2018/01/22 17:41:42 UTC
[36/38] storm git commit: STORM-2153: add taskId to user-defined
metrics names
STORM-2153: add taskId to user-defined metrics names
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/1d42d8fb
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/1d42d8fb
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/1d42d8fb
Branch: refs/heads/1.x-branch
Commit: 1d42d8fb59f5870a671a8cb5c02e1cf46f08a22f
Parents: 7947a07
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Fri Jan 12 14:05:34 2018 -0500
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Fri Jan 12 14:05:34 2018 -0500
----------------------------------------------------------------------
.../src/jvm/org/apache/storm/metrics2/StormMetricRegistry.java | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/1d42d8fb/storm-core/src/jvm/org/apache/storm/metrics2/StormMetricRegistry.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/org/apache/storm/metrics2/StormMetricRegistry.java b/storm-core/src/jvm/org/apache/storm/metrics2/StormMetricRegistry.java
index e0023fd..cfeb711 100644
--- a/storm-core/src/jvm/org/apache/storm/metrics2/StormMetricRegistry.java
+++ b/storm-core/src/jvm/org/apache/storm/metrics2/StormMetricRegistry.java
@@ -162,6 +162,8 @@ public class StormMetricRegistry {
}
public static String metricName(String name, TopologyContext context){
+
+
StringBuilder sb = new StringBuilder("storm.topology.");
sb.append(context.getStormId());
sb.append(".");
@@ -169,6 +171,8 @@ public class StormMetricRegistry {
sb.append(".");
sb.append(dotToUnderScore(context.getThisComponentId()));
sb.append(".");
+ sb.append(context.getThisTaskId());
+ sb.append(".");
sb.append(context.getThisWorkerPort());
sb.append("-");
sb.append(name);