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 825363b [BEAM-9147] Add a VideoIntelligence transform to Java SDK
(#11261)
add e325044 [BEAM-9580] Allow Flink 1.10 processing timers to finish on
pipeline shutdown
add d4790fd Revert "[BEAM-9580] Downgrade Flink version to 1.9 for
Nexmark and ValidatesRunner"
add b6dbf2a [BEAM-9557] Fix strings used to verify test output
add e7f6ccb Merge pull request #11346: [BEAM-9580] Allow Flink 1.10
processing timers to finish on pipeline shutdown
No new revisions were added by this update.
Summary of changes:
.test-infra/jenkins/CommonTestProperties.groovy | 2 +-
.../job_PostCommit_Java_Nexmark_Flink.groovy | 12 +++--
...ob_PostCommit_Java_ValidatesRunner_Flink.groovy | 2 +-
.../flink/translation/utils/Workarounds.java | 25 +++++++++++
.../wrappers/streaming/DoFnOperator.java | 52 +++++++++++++++++-----
.../streaming/ExecutableStageDoFnOperator.java | 8 ++--
.../wrappers/streaming/SplittableDoFnOperator.java | 11 ++---
.../wrappers/streaming/WindowDoFnOperator.java | 9 ++--
.../org/apache/beam/sdk/transforms/ParDoTest.java | 13 ++++--
9 files changed, 96 insertions(+), 38 deletions(-)
