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 <[email protected]> Authored: Fri Jan 12 14:05:34 2018 -0500 Committer: P. Taylor Goetz <[email protected]> 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);
