As part of the development of streamparse, we have a BatchingBolt that 
processes tuples in batches. It's intended for use with things like databases 
that are more performant when you send things in batches.

I've recently proposed switching our BatchingBolt implementation over from 
using a timer/thread approach to using tick tuples; however, one of my fellow 
devs pointed out that with our current approach the final batch will definitely 
get processed when a topology is shutdown (and it's in the inactive state), 
whereas that won’t happen if tick tuples aren’t arriving to trigger batch 
processing.  Unfortunately, whether or not tick tuples keep getting sent when I 
topology is inactive isn't explicitly documented anywhere I can find.

Therefore, my question is this: does Storm continue sending tick tuples to 
bolts after a kill/deactivate has been issued, while it is in the 
waiting/inactive period? The topology lifecycle docs don't make it clear.

Thanks,

Dan

PS: I also posted this as a StackOverflow question, if you want to respond 
there.


Reply via email to