Hello again,

I'm running a topology with one spout (1 executor and 1 task) and one bolt (1 executor and n tasks). As I am using a metrics' consumer for monitoring, I expect to receive one message per task each bucket.size seconds. However, it appears that my metrics' consumer always receives n^2 + 1 messages, each bolt task sending n messages. Any idea why?

I'm on Apache Storm 0.9.1.

Cheers,
Ahmed

Reply via email to