Stephen, During my exploration I got some use out of this video:
http://youtu.be/iLZrYPbNypg Craig Charleton [email protected] > On Nov 7, 2015, at 11:26 PM, Stephen Powis <[email protected]> wrote: > > So this question may be better suited for the dev mailing list, but > I'll give this a shot. > > I'm trying to better understand the acker behavior and how it deals > with tuple time outs. I've read the documentation on the storm > website, but from my rudimentary knowledge of clojure, it seems like > the docs and the code don't completely align. > > The short of it is I'm wondering if the line linked in acker.clj > resets the tuple timeout value every time a bolt acks a tuple: > https://github.com/apache/storm/blob/master/storm-core/src/clj/backtype/storm/daemon/acker.clj#L65 > > It seems like for every tuple coming into the acker, it calls > rotatingMap.put() on the instance, which in turn resets its timeout > countdown. > > Does this sound correct?
