GitHub user mxm opened a pull request:
https://github.com/apache/incubator-beam/pull/967
[BEAM-283] finalize CheckpointMarks upon completed checkpoint
See the first commit for an addition to the `UnboundedSourceWrapper` to
call `finalizeCheckpoint()` on `CheckpointMark`s upon checkpoint completion.
The second commits contains a potential race condition upon startup of the
source wrapper when checkpointing is enabled.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mxm/incubator-beam BEAM-283
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/incubator-beam/pull/967.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 #967
----
commit cf14e809d4a790c407ab7c3cf1c90bb436a86dc9
Author: Maximilian Michels <m...@apache.org>
Date: 2016-09-16T15:04:22Z
[BEAM-283] finalize CheckpointMarks upon completed checkpoint
commit b82208b22adab641f3c469bef622d0a76be88d68
Author: Maximilian Michels <m...@apache.org>
Date: 2016-09-16T16:42:43Z
fix potential NPE in checkpointing of UnboundedSourceWrapper
This moves all the initialization code to the open() method which ensures
that no snapshot can occur before the state has been initialized correctly.
----
---
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 infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
