You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by tg...@apache.org on 2018/05/18 17:35:51 UTC
[beam] 01/01: Merge pull request #4793: Stop adding holds behind
the watermark for merging late windows
This is an automated email from the ASF dual-hosted git repository.
tgroh pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit fc7ddf2d828e4bb3709f4d0dfa81e92806f02966
Merge: c3a80b2 9452aca
Author: Thomas Groh <tg...@users.noreply.github.com>
AuthorDate: Fri May 18 10:35:46 2018 -0700
Merge pull request #4793: Stop adding holds behind the watermark for merging late windows
[BEAM-3776] Fix issue with merging late windows where a watermark hold could be added behind the input watermark.
pom.xml | 7 +
runners/core-java/build.gradle | 2 +-
runners/core-java/pom.xml | 7 +-
.../org/apache/beam/runners/core/StateMerging.java | 95 ---------
.../apache/beam/runners/core/WatermarkHold.java | 74 ++++++-
.../beam/runners/core/ReduceFnRunnerTest.java | 222 ++++++++++++++++++++-
.../apache/beam/runners/core/ReduceFnTester.java | 8 +-
.../beam/runners/core/StateInternalsTest.java | 42 ----
.../FlinkBroadcastStateInternalsTest.java | 8 -
.../streaming/FlinkKeyGroupStateInternalsTest.java | 8 -
.../streaming/FlinkSplitStateInternalsTest.java | 8 -
.../test/java/org/apache/beam/sdk/io/ReadTest.java | 5 +
12 files changed, 313 insertions(+), 173 deletions(-)
--
To stop receiving notification emails like this one, please contact
tgroh@apache.org.