This is an automated email from the ASF dual-hosted git repository. mxm pushed a commit to branch release-2.21.0 in repository https://gitbox.apache.org/repos/asf/beam.git
commit 602f00d7da4a54dd665970841ee2a98da0a6400c Merge: 36f19f0 b3479aa Author: Maximilian Michels <[email protected]> AuthorDate: Mon Apr 27 20:13:40 2020 +0200 Merge pull request #11536: [BEAM-9827] Ensure minimum watermark hold is computed across all keys Backport of #11533. .../wrappers/streaming/DoFnOperator.java | 5 +- .../streaming/state/FlinkStateInternals.java | 93 ++++++++++------------ .../FlinkBroadcastStateInternalsTest.java | 0 .../flink/streaming/FlinkStateInternalsTest.java | 51 +++++++++--- 4 files changed, 86 insertions(+), 63 deletions(-)
