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/01/23 20:13:56 UTC

(beam) 01/01: Merge pull request #30066: [flink] Fix watermark generation for empty UnboundedSource

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 90e7c9e8f6b59d17fdb0d995db6faec2d72d8680
Merge: cffeff78f62 58650378fe7
Author: Jan Lukavský <je...@seznam.cz>
AuthorDate: Tue Jan 23 21:13:48 2024 +0100

    Merge pull request #30066: [flink] Fix watermark generation for empty UnboundedSource

 .../streaming/io/source/FlinkSourceReaderBase.java |   1 +
 .../unbounded/FlinkUnboundedSourceReader.java      |  13 ++-
 .../streaming/io/source/EmptyUnboundedSource.java  | 101 +++++++++++++++++++++
 .../io/source/FlinkSourceReaderTestBase.java       |   8 ++
 .../unbounded/FlinkUnboundedSourceReaderTest.java  |  33 +++++++
 5 files changed, 154 insertions(+), 2 deletions(-)