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 <[email protected]> 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 [email protected].
