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:02 UTC
[beam] branch master updated (5b6d6c9 -> b5d3a3a)
This is an automated email from the ASF dual-hosted git repository.
mxm pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 5b6d6c9 Merge pull request #7077: [BEAM-6009] gradle config for batch+streaming portable flink vr tests
add ec5a9c3 [BEAM-6116] [portable flink streaming] Emit pushed back watermark when bundle is complete.
new b5d3a3a Merge pull request #7124: [BEAM-6116] [portable flink streaming] Emit pushed back watermark when bundle is complete
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../wrappers/streaming/ExecutableStageDoFnOperator.java | 13 ++++++++-----
.../flink/streaming/ExecutableStageDoFnOperatorTest.java | 15 ++++++++++++++-
2 files changed, 22 insertions(+), 6 deletions(-)
[beam] 01/01: Merge pull request #7124: [BEAM-6116] [portable flink
streaming] Emit pushed back watermark when bundle is complete
Posted by mx...@apache.org.
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(-)