This is an automated email from the ASF dual-hosted git repository.
reuvenlax pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 7a9433b Merge pull request #15132 from tysonjh/py-container-update
add 2c6f42c Merge pull request #15056: [BEAM-10887] Timer clear
No new revisions were added by this update.
Summary of changes:
.../beam/runners/core/InMemoryTimerInternals.java | 3 +-
.../apache/beam/runners/core/SimpleDoFnRunner.java | 5 +
.../apache/beam/runners/core/TimerInternals.java | 20 +-
.../beam/runners/direct/DirectTimerInternals.java | 58 +-
.../direct/StatefulParDoEvaluatorFactory.java | 56 +-
.../beam/runners/direct/WatermarkManager.java | 89 ++-
.../wrappers/streaming/DoFnOperator.java | 4 +-
.../streaming/ExecutableStageDoFnOperator.java | 3 +-
runners/google-cloud-dataflow-java/build.gradle | 1 -
.../worker/StreamingModeExecutionContext.java | 96 ++-
.../dataflow/worker/WindmillTimerInternals.java | 39 +-
.../beam/runners/samza/runtime/KeyedInternals.java | 5 +-
.../samza/runtime/SamzaTimerInternalsFactory.java | 3 +-
.../spark/stateful/SparkTimerInternals.java | 2 +-
.../main/java/org/apache/beam/sdk/state/Timer.java | 3 +
.../org/apache/beam/sdk/transforms/ParDoTest.java | 807 +++++++++++++++------
.../apache/beam/fn/harness/FnApiDoFnRunner.java | 11 +
.../beam/fn/harness/FnApiDoFnRunnerTest.java | 16 +
18 files changed, 913 insertions(+), 308 deletions(-)
