This is an automated email from the ASF dual-hosted git repository. mxm pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit f56c86f874a13341d90fdb1aa46d86f8d739cd39 Merge: ec6384a ea275e4 Author: Maximilian Michels <[email protected]> AuthorDate: Sun Dec 30 21:07:42 2018 +0100 Merge pull request #7349: [BEAM-5386] Prevent CheckpointMarks from not getting acknowledged .../streaming/io/UnboundedSourceWrapper.java | 34 +++++++++-- .../flink/streaming/BoundedSourceRestoreTest.java | 1 + .../wrappers/streaming/io}/TestCountingSource.java | 2 +- .../streaming/io}/UnboundedSourceWrapperTest.java | 70 +++++++++++++++++----- 4 files changed, 87 insertions(+), 20 deletions(-)
