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. ---