It should work. Did you assign message IDs in your spout? On 05/25/2016 01:21 PM, Navin Ipe wrote: > I created a spout that emits to a bolt (extends BaseRichBolt) using > allGrouping. > At the end of execute() I am doing collector.ack(tuple); > > But I'm not receiving anything in the ack() or fail() of the spout, even > though the two created instances (tasks) of the blot have received the > tuple from the spout and ack'ed it. The documentation has nothing on it > either > <https://storm.apache.org/releases/0.9.6/javadocs/backtype/storm/topology/InputDeclarer.html#allGrouping-java.lang.String-java.lang.String->. > > Is this how allGrouping is meant to work? Without ack or fail? > > -- > Regards, > Navin
signature.asc
Description: OpenPGP digital signature
