GitHub user arunmahadevan opened a pull request:
https://github.com/apache/storm/pull/1190
[STORM-1608] Fix stateful topology acking behavior
Right now the acking is automatically taken care of for the non-stateful
bolts in a stateful topology. This leads to double acking if BaseRichBolts are
part of the topology and the acking does not complete and tuples are re-emitted.
For the non-stateful bolts, its better to let the bolt do the acking rather
than automatically acking.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/arunmahadevan/storm STORM-1608
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/storm/pull/1190.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #1190
----
commit c0bce3e470ca4d502ee4d2ee953e06e0c0fa96c5
Author: Arun Mahadevan <[email protected]>
Date: 2016-03-07T06:00:35Z
[STORM-1608] Fix stateful topology acking behavior
Right now the acking is automatically taken care of for the non-stateful
bolts in a stateful topology.
This leads to double acking if BaseRichBolts are part of the topology.
For the non-stateful bolts, its better to let the bolt do the acking rather
than automatically acking.
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
