I added metrics to my storm implementation by implementing IMetric. It is working and can see the metrics log populated with all stats. I've a 3 node (3 worker) and 1 nimbus/zookeeper in Development.
On WORKER1's Metrics Log I can see , some metrics with reference to WORKER2 and WORKER3. For example, 2014-04-22 16:42:14,829 23002 1398184934 *worker3*:9953 17:normalizeBolt null {bolt.timeconsumed={8, 1657, 5135, 41}} 2014-04-22 16:42:14,830 23003 1398184934 *worker3*:9953 38:normalizeBolt null {db.searchip={3, 77, 221, 7}, fetch-doc={3, 32, 101, 8}} 2014-04-22 16:42:14,833 23006 1398184934 *worker3*:9953 31:normalizeBolt null {bolt.timeconsumed={7, 1638, 5036, 36}} 2014-04-22 16:42:14,833 23006 1398184934 *worker3*:9953 10:normalizeBolt null {db.searchip={3, 86, 165, 6}, fetch-doc={3, 17, 53, 7}} 2014-04-22 16:42:14,865 23038 1398184934 *worker1*:9953 44:normalizeSpout null {spout.timeconsumed={656, 8454, 56490, 10}} *My questions, * Why I'm seeing the stats of WORKER3 in WORKER1's log file ? My expectation was each worker will just log it's own metrics and it's upto the log collector (like splunk or logstash) to merge and interpret. Thanks, Prasun