You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by Rahul <ra...@incture.com> on 2015/07/15 07:37:32 UTC
Re-emitting failed tuples
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
Re: Re-emitting failed tuples
Posted by Rahul <ra...@incture.com>.
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 (mjsax@informatik.hu-berlin.de) 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*
>
Re: Re-emitting failed tuples
Posted by "Matthias J. Sax" <mj...@informatik.hu-berlin.de>.
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*
>