GitHub user srdo opened a pull request:
https://github.com/apache/storm/pull/2538
STORM-2913: Add metadata to at-most-once and at-least-once commits
https://issues.apache.org/jira/browse/STORM-2913
This builds on STORM-2914.
I believe we can resolve STORM-2913 by committing metadata in all
processing guarantee modes, rather than just AT_LEAST_ONCE. This change simply
adds metadata to the AT_MOST_ONCE and NONE commit statements.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/srdo/storm STORM-2913
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/storm/pull/2538.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 #2538
----
commit 3e09a1d718f8d40424e7ac5d574efe7a74706cf8
Author: Stig Rohde Døssing <srdo@...>
Date: 2018-01-27T18:22:07Z
STORM-2914: Implement ProcessingGuarantee.NONE in the spout instead of
using enable.auto.commit
commit 99c7a30bf38c523a1f97411e7a42dbb44017f9f0
Author: Stig Rohde Døssing <srdo@...>
Date: 2018-01-27T14:15:45Z
STORM-2913: Add metadata to at-most-once and at-least-once commits
----
---
