this change was causing a weird exception in nimbus, reverting it.

jasonjckn · Nov 9, 2012 · ffd8ac4 · ffd8ac4
1 parent 863669e
commit ffd8ac4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/clj/backtype/storm/daemon/common.clj b/src/clj/backtype/storm/daemon/common.clj
@@ -239,7 +239,7 @@
   (->> (get storm-conf TOPOLOGY-METRICS-CONSUMER-REGISTER)         
        (map #(get % "class"))
        (number-duplicates)
-       (map #(str Constants/METRICS_COMPONENT_ID_PREFIX "_" %))))
+       (map #(str Constants/METRICS_COMPONENT_ID_PREFIX %))))
 
 (defn metrics-consumer-bolt-specs [components-ids-that-emit-metrics storm-conf]
   (let [inputs (->> (for [comp-id components-ids-that-emit-metrics]