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
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
