Hi Cheney, Replays happen at the spout level. So if there is a failure at any point in the tuple tree (the tuple tree being the anchored emits, unanchored emits don’t count), the original spout tuple will be replayed. So the replayed tuple will traverse the topology again, including unanchored points.
If an unanchored tuple fails downstream, it will not trigger a replay. Hope this helps. -Taylor > On Sep 13, 2016, at 4:42 AM, Cheney Chen <tbcql1...@gmail.com> wrote: > > Hi there, > > We're using storm 1.0.1, and I'm checking through > http://storm.apache.org/releases/1.0.1/Guaranteeing-message-processing.html > <http://storm.apache.org/releases/1.0.1/Guaranteeing-message-processing.html> > > Got questions for below two scenarios. > Assume topology: S (spout) --> BoltA --> BoltB > 1. S: anchored emit, BoltA: anchored emit > Suppose BoltB processing failed w/ ack, what will the replay be, will it > execute both BoltA and BoltB or only failed BoltB processing? > > 2. S: anchored emit, BoltA: unanchored emit > Suppose BoltB processing failed w/ ack, replay will not happen, correct? > > -- > Regards, > Qili Chen (Cheney) > > E-mail: tbcql1...@gmail.com <mailto:tbcql1...@gmail.com> > MP: (+1) 4086217503
signature.asc
Description: Message signed with OpenPGP using GPGMail
