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/02/06 07:40:23 UTC

(beam) 01/01: Merge pull request #30141: Adding a default watermark emit interval for FlinkUnboundedSourceReader

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 cd5f2711c83071b8630f5c3c701b1fda59b1a74a
Merge: d5aa44c9ba9 a341eb69abe
Author: Jan Lukavský <je...@seznam.cz>
AuthorDate: Tue Feb 6 08:40:15 2024 +0100

    Merge pull request #30141: Adding a default watermark emit interval for FlinkUnboundedSourceReader

 .../unbounded/FlinkUnboundedSourceReader.java      | 36 +++++++++++++---------
 1 file changed, 22 insertions(+), 14 deletions(-)