If you emit with a messageId, then the tuple will be tracked from the spout. Then if you anchor in the bolts, the bolt's tuples will also be tracked. If you don't want your tuples to be tracked at all then disabled the ackers (as you have done) or emit without a message ID in the spout.
On Tue, Mar 17, 2015 at 11:45 AM, hjh <[email protected]> wrote: > Thank you! I know that but we are still unable to find the problem. If I > turn on the acker but do not anchor the tuple does that mean the tuple will > still not be processed in a reliable way? > > > On 03/17/2015 11:28 AM, Nathan Leung wrote: > > No, you need something to process the acks otherwise there's no way to > tell what has processed successfully and what is timing out. It's better > to figure out why enabling acking is causing your topology to fail. That > sounds ... bad. > > On Tue, Mar 17, 2015 at 11:07 AM, hjh <[email protected]> wrote: > >> Thank you very much for the quick response. By the way I forgot to tell >> that I disabled the acker in the topology since the topology may die after >> a few seconds if I do not turn off ackers. In this case is it still >> possible to do guaranteed message processing for some of the bolts? Thank >> you!! >> >> >> On 03/17/2015 10:16 AM, Nathan Leung wrote: >> >> When you emit from bolt c do not anchor the output tuple to the input >> tuple. >> On Mar 17, 2015 9:55 AM, "hjh" <[email protected]> wrote: >> >>> Hi everyone, >>> I am confused about reliability API of storm. It seems that >>> guaranteed message processing is only for spout. What if I need to >>> guarantee message being processed in a subset of bolts? For example, bolt >>> A, B, C are connected and tuples are processed from A to B and to C, what >>> should I do if I want tuples passed through these three bolts being >>> processed fully? I mean once a tuple is passed to A then I should make sure >>> that this tuple is processed in B and C but after that I do not care >>> whether it is lost or not? Thank you very much!! >>> >>> Best wishes!! >>> >>> >> > >
