Thanks Matthias. I am using my own Spout implementation. I was under the assumption that Storm, by default, re-emits the tuples when Spout.fail() is called. Now I realize I have to implement the changes myself.
Could you let me know about any Spout which has done the re-emit implementation? I can use it as reference. -- Rahul J On July 15, 2015 at 1:18:56 PM, Matthias J. Sax ([email protected]) wrote: 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* >
