Apart from the previous question, there's also the question of whether we should ack the tuple in execute() of Bolt1? Or is it just sufficient to ack it in Bolt2?
On Wed, Nov 30, 2016 at 12:28 PM, Navin Ipe <[email protected] > wrote: > Hi, > > Just need a confirmation for this topology: > > *Spout* ---emit---> *Bolt1* ---emit---> *Bolt2* > > Spout is BaseRichSpout. Bolt1 and Bolt2 are BaseRichBolt. > Spout emits just one tuple per nextTuple() call. > Bolt1 anchors to the tuple it received from Spout and emits many different > tuple objects. > > If any of the emits of Bolt1 fails, is there no way for Bolt 1 to re-emit > the tuple? Do I have to wait for the topology to figure out that one of > Bolt1's tuples failed and then do a re-emit from the Spout? > > -- > Regards, > Navin > -- Regards, Navin
