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 e477c1b [BEAM-12584] Fix sample and make tag in documentation point to correct sample. (#15133) add 2809141 Revert "Merge pull request #15056: [BEAM-10887] Timer clear" add b9d5c40 Merge pull request #15134: Revert "[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, 308 insertions(+), 913 deletions(-)