Bingo. Assigning the messageID did it. Thank you. On Wed, May 25, 2016 at 8:55 PM, Matthias J. Sax <[email protected]> wrote:
> 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 > > -- Regards, Navin
