I'm an idiot. I don't know how I missed that in the api. Thanks! On May 31, 2014 10:47 AM, "Harsha" <[email protected]> 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 > >
