Hi group,
Say I'm doing a moving average on real time data from storm.
I am interested in dealing with failed tuples.

If I can't save the average to the db (for whatever reason), the tuple is 
failed which in turn makes storm re send it. The moving average bolt needs to 
somehow know if a tuple is a resend or a new one so that if it's a resend it 
doesn't try to add it to the average (it being already part of the average). Is 
there a parameter in tuple that tells if the tuple is a resend or a new one?

Thanks
-Adrian

Reply via email to