Github user zd-project commented on a diff in the pull request: https://github.com/apache/storm/pull/2714#discussion_r195467563 --- Diff: storm-server/src/main/java/org/apache/storm/metric/StormMetricsRegistry.java --- @@ -73,6 +130,12 @@ private static void startMetricsReporter(PreparableReporter reporter, Map<String } private static <T extends Metric> T register(String name, T metric) { + if (source != null && !name.startsWith(source)) { --- End diff -- Thanks for the clarification. Anyone else also has suggestions in the implementation?
---