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
