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
