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 2020/12/18 17:38:22 UTC

[beam] 01/01: Merge pull request #13571: [BEAM-11481] emit output watermark on watermark hold change

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 bea6f88b747dd582b0df6db1c265846f304c6abf
Merge: 80248d0 8de6faa
Author: Jan Lukavský <je...@seznam.cz>
AuthorDate: Fri Dec 18 18:37:27 2020 +0100

    Merge pull request #13571: [BEAM-11481] emit output watermark on watermark hold change

 .../wrappers/streaming/DoFnOperator.java           |  23 ++-
 .../streaming/KeyedPushedBackElementsHandler.java  |   5 +-
 .../streaming/state/FlinkStateInternals.java       |   4 +-
 .../wrappers/streaming/DoFnOperatorTest.java       | 169 ++++++++++++++++++++-
 4 files changed, 194 insertions(+), 7 deletions(-)