For the storm topology we did graceful shutdown by setting the wait time with 
-w flag. This causes the topology to be deactivated for the wait time before 
its actually shut down. This gives the topology a chance to finish processing 
what it's currently processing before shutting down the workers.
In case of Trident. . for some reason if the tuple was not processed then it 
will be reprocessed next time the topology comes up given the guaranteed 
exactly once processing of Trident (if implemented correctly).

Reply via email to