commit 1d42d8fb59f5870a671a8cb5c02e1cf46f08a22f
author P. Taylor Goetz <ptgoetz@gmail.com> Fri Jan 12 14:05:34 2018 -0500
committer P. Taylor Goetz <ptgoetz@gmail.com> Fri Jan 12 14:05:34 2018 -0500
tree f4a0ae98137dccf47742072c2be302d5900f1d53
parent 7947a0755c6717de16a7755ec7f1f2dc83388d11

STORM-2153: add taskId to user-defined metrics names

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 static String metricName(String name, TopologyContext context){
+
+
         StringBuilder sb = new StringBuilder("storm.topology.");
         sb.append(context.getStormId());
         sb.append(".");
@@ -169,6 +171,8 @@
         sb.append(".");
         sb.append(dotToUnderScore(context.getThisComponentId()));
         sb.append(".");
+        sb.append(context.getThisTaskId());
+        sb.append(".");
         sb.append(context.getThisWorkerPort());
         sb.append("-");
         sb.append(name);