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%)
