This is an automated email from the ASF dual-hosted git repository.
yhu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from ec31847d934 Skip calling Compute in RemoveSafeDeltaCounterCell if
value exists (#30913)
add a62dfa732d4 [Flink] finalize checkpoint marks in the new Flink source
implementation (#30849) (#30987)
No new revisions were added by this update.
Summary of changes:
.../streaming/io/source/FlinkSourceSplit.java | 3 ++
.../unbounded/FlinkUnboundedSourceReader.java | 27 +++++++------
.../unbounded/FlinkUnboundedSourceReaderTest.java | 45 ++++++++++++++++------
3 files changed, 50 insertions(+), 25 deletions(-)
