You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by mx...@apache.org on 2018/11/23 10:00:03 UTC

[beam] 01/01: Merge pull request #7124: [BEAM-6116] [portable flink streaming] Emit pushed back watermark when bundle is complete

This is an automated email from the ASF dual-hosted git repository.

mxm pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit b5d3a3a582f87ba38fec024a04e62c3a5b90915d
Merge: 5b6d6c9 ec5a9c3
Author: Maximilian Michels <mx...@apache.org>
AuthorDate: Fri Nov 23 10:59:54 2018 +0100

    Merge pull request #7124: [BEAM-6116] [portable flink streaming] Emit pushed back watermark when bundle is complete

 .../wrappers/streaming/ExecutableStageDoFnOperator.java   | 13 ++++++++-----
 .../flink/streaming/ExecutableStageDoFnOperatorTest.java  | 15 ++++++++++++++-
 2 files changed, 22 insertions(+), 6 deletions(-)