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 2022/05/05 08:02:50 UTC

[beam] 01/01: Merge pull request #17504: [BEAM-14196] add test verifying output watermark propagation in bundle

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 3ac86e46e827a0874f051a2c7035d4c01f0caa56
Merge: e7d3e8c9814 51e882c0309
Author: Jan Lukavský <je...@seznam.cz>
AuthorDate: Thu May 5 10:02:42 2022 +0200

    Merge pull request #17504: [BEAM-14196] add test verifying output watermark propagation in bundle

 .../wrappers/streaming/DoFnOperator.java           | 46 ++++++++++++++---
 .../streaming/ExecutableStageDoFnOperator.java     | 12 ++---
 .../beam/runners/flink/FlinkSavepointTest.java     |  2 +-
 .../wrappers/streaming/DoFnOperatorTest.java       | 35 ++++++-------
 .../streaming/ExecutableStageDoFnOperatorTest.java |  3 +-
 .../wrappers/streaming/WindowDoFnOperatorTest.java |  9 ++++
 .../org/apache/beam/sdk/transforms/ParDoTest.java  | 58 +++++++++++++++++++++-
 7 files changed, 129 insertions(+), 36 deletions(-)