ben.tse (1) [Avatar] Offline
In 4.4.3 Explicit Anchoring, Acking and Failing: one of the scenarios listed, where one would move beyond BaseBasicBolt is taking one tuple and emitting multiple tuples (expanding). This seems incorrect. BasicBoltExecutor would ack on the incoming tuple after the bolt's execute() method, regardless if the execute() method emitted one or multiple tuples. Unless acking the incoming tuple before finishing emitting all potential downstream tuple is desirable, BaseBasicBolt should be suffice.

reference: Storm 0.9.1-incubating
matthew.jankowski (17) [Avatar] Offline
You are correct. Nice catch. Updating for the final manuscript.