MetricsConsumer bugfix introduced in #554 about metrics names

apache · Apr 9, 2018 · 6e79d98 · 6e79d98
1 parent b39b37c
commit 6e79d98
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...h/src/main/java/com/digitalpebble/stormcrawler/elasticsearch/metrics/MetricsConsumer.java b/...h/src/main/java/com/digitalpebble/stormcrawler/elasticsearch/metrics/MetricsConsumer.java
@@ -97,7 +97,7 @@ private void handleDataPoints(final TaskInfo taskInfo,
             Iterator<Entry> keyValiter = ((Map) value).entrySet().iterator();
             while (keyValiter.hasNext()) {
                 Entry entry = keyValiter.next();
-                String newnameprefix = "." + entry.getKey();
+                String newnameprefix = nameprefix + "." + entry.getKey();
                 handleDataPoints(taskInfo, newnameprefix, entry.getValue(), now);
             }
         } else if (value instanceof Collection) {

diff --git a/external/solr/src/main/java/com/digitalpebble/stormcrawler/solr/metrics/MetricsConsumer.java b/external/solr/src/main/java/com/digitalpebble/stormcrawler/solr/metrics/MetricsConsumer.java
@@ -86,7 +86,7 @@ private void handleDataPoints(final TaskInfo taskInfo,
             Iterator<Entry> keyValiter = ((Map) value).entrySet().iterator();
             while (keyValiter.hasNext()) {
                 Entry entry = keyValiter.next();
-                String newnameprefix = "." + entry.getKey();
+                String newnameprefix = nameprefix + "." + entry.getKey();
                 handleDataPoints(taskInfo, newnameprefix, entry.getValue(), now);
             }
         } else if (value instanceof Collection) {