What Spout do you use? Failing tuples result in back-calls to Spout.fail(). If you use your own Spout implementation, you need to overwrite this method. The default implementation does nothing. Or do you already use a (so-called) reliable Spout?
-Matthias On 07/15/2015 07:37 AM, Rahul wrote: > Hi, > > As per the Storm documentation, all the failed tuples will be re-emitted > by the Spout to the corresponding Bolts. I am testing a sample topology > in which I do not acknowledge any of my tuples and hence I see the log > being printed for all the failed tuples but none of the tuples are > re-emitted. > > -- > *Rahul J* >
signature.asc
Description: OpenPGP digital signature
