Hi,

I measure the latency of a storm topology in the below two ways. And I see
a huge difference in the values.

*Approach 1*: attach a start time with every tuple. Note the end time for
that tuple in ack(). Calculate the time delta of start and end times.

Latency value is ~ 104 ms.

*Approach 2*: Using Storm UI parameter "complete Latency" to measure
latency.

Latency value is ~ 2-3 ms.

Could someone please explain why is there a huge difference in Latency
calculations?
If not on timestamp basis, how does storm internal metrics system calculate
the complete latency?

Thanks,
Preethini

Reply via email to