You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@storm.apache.org by Phil Burress <ph...@gmail.com> on 2014/05/31 13:57:47 UTC

Explicitly Fail Tuple for Replay?

Is there a way to explicitly fail a tuple for replay later? Or do I have to
just let it time out for storm to replay it? Does throwing a
backtype.storm.topology.FailedException allow storm to replay a tuple?

Thanks!

-Phil

Re: Explicitly Fail Tuple for Replay?

Posted by Phil Burress <ph...@gmail.com>.

I'm an idiot. I don't know how I missed that in the api.

Thanks!
On May 31, 2014 10:47 AM, "Harsha" <st...@harsha.io> wrote:

>
> Phil,
>     You can do collector.fail(tuple)
>
> http://storm.incubator.apache.org/apidocs/backtype/storm/task/OutputCollector.html#fail%28backtype.storm.tuple.Tuple%29
> -Harsha
>
>
> On Sat, May 31, 2014, at 04:57 AM, Phil Burress wrote:
>
> Is there a way to explicitly fail a tuple for replay later? Or do I have
> to just let it time out for storm to replay it? Does throwing a
> backtype.storm.topology.FailedException allow storm to replay a tuple?
>
> Thanks!
>
> -Phil
>
>

Re: Explicitly Fail Tuple for Replay?

Posted by Harsha <st...@harsha.io>.


Phil,

    You can do collector.fail(tuple)

[1]http://storm.incubator.apache.org/apidocs/backtype/storm/task/Output
Collector.html#fail%28backtype.storm.tuple.Tuple%29

-Harsha





On Sat, May 31, 2014, at 04:57 AM, Phil Burress wrote:

Is there a way to explicitly fail a tuple for replay later? Or do I
have to just let it time out for storm to replay it? Does throwing a
backtype.storm.topology.FailedException allow storm to replay a tuple?

Thanks!

-Phil

References

1. http://storm.incubator.apache.org/apidocs/backtype/storm/task/OutputCollector.html#fail%28backtype.storm.tuple.Tuple%29