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 2020/04/27 15:57:10 UTC

[beam] branch master updated (ec8f60a -> 439728a)

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 ec8f60a  Merge pull request #11531: [BEAM-9826] Update TikaIO to use Tika version 1.24.1
     add 0d12aa5  [BEAM-9827] Ensure minimum watermark hold is computed across all keys
     add 439728a  Merge pull request #11533: [BEAM-9827] Ensure minimum watermark hold is computed across all keys

No new revisions were added by this update.

Summary of changes:
 .../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(-)
 rename runners/flink/{1.8 => }/src/test/java/org/apache/beam/runners/flink/streaming/FlinkBroadcastStateInternalsTest.java (100%)
 rename runners/flink/{1.8 => }/src/test/java/org/apache/beam/runners/flink/streaming/FlinkStateInternalsTest.java (72%)