Hello folks,
I have been trying to monitor Storm programatically, first using the
Thrift interface, and recently using the MetricsConsumer.
I have run the Exclamation Topology, with a 10ms delay between each two
consecutive emissions. Each component runs on a separate worker, with
one executor and one task, the number of ackers is set to 0 and the size
of the metrics' bucket is 10s.
The attached figure shows a rather strange behavior of the number of
emitted tuples. Can anybody explain this oscillation?
Thanks in advance for your help.
Cheers,
Ahmed
