You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by ja...@apache.org on 2024/04/15 17:35:08 UTC

(beam) 01/01: Merge pull request #30969: [runners-flink] Fix watermark emission for empty splits (#29816)

This is an automated email from the ASF dual-hosted git repository.

janl pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit e119cd49cf9f65916434443c3968dbd53d94f086
Merge: 4b808b0d4f5 d680bf0a57d
Author: Jan Lukavský <je...@seznam.cz>
AuthorDate: Mon Apr 15 19:35:00 2024 +0200

    Merge pull request #30969: [runners-flink] Fix watermark emission for empty splits (#29816)

 .../streaming/io/source/FlinkSourceReaderBase.java | 49 ++++++++++++----------
 .../streaming/io/source/FlinkSourceSplit.java      |  8 ++--
 .../io/source/FlinkSourceSplitEnumerator.java      |  5 ++-
 .../unbounded/FlinkUnboundedSourceReader.java      | 35 +++++++---------
 .../unbounded/FlinkUnboundedSourceReaderTest.java  | 12 ++++++
 5 files changed, 63 insertions(+), 46 deletions(-)