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ý <[email protected]> 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(-)
