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 836e77e755ba52fb55910308ba5324b01f787079 Merge: 0790d698251 5a822adc269 Author: Jan Lukavský <[email protected]> AuthorDate: Sat May 25 19:32:15 2024 +0200 Merge pull request #31391: [flink] #31390 emit watermark with empty source .../streaming/io/source/FlinkSourceReaderBase.java | 9 ++-- .../unbounded/FlinkUnboundedSourceReader.java | 8 ++-- .../streaming/io/source/EmptyUnboundedSource.java | 4 +- .../unbounded/FlinkUnboundedSourceReaderTest.java | 54 ++++++++++++++++++++-- 4 files changed, 63 insertions(+), 12 deletions(-)
