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 dce846b Merge pull request #15247: [BEAM-12686] Enable self-managed relative timers add 8bd1e20 Ensure timer consistency in Dataflow and portable runners add 7b54b0b Merge pull request #15123: Ensure timer consistency in runners No new revisions were added by this update. Summary of changes: .../apache/beam/runners/core/TimerInternals.java | 1 + runners/direct-java/build.gradle | 2 + runners/google-cloud-dataflow-java/build.gradle | 2 - .../worker/StreamingModeExecutionContext.java | 129 ++++++++--- .../dataflow/worker/WindmillTimerInternals.java | 47 ++-- ...sesStatefulParDo.java => UsesLoopingTimer.java} | 4 +- .../sdk/transforms/reflect/DoFnSignatures.java | 3 +- .../org/apache/beam/sdk/transforms/ParDoTest.java | 77 ++++--- .../apache/beam/fn/harness/FnApiDoFnRunner.java | 175 ++++++++++----- .../fn/harness/state/FnApiTimerBundleTracker.java | 224 +++++++++++++++++++ .../beam/fn/harness/FnApiDoFnRunnerTest.java | 238 +++++++++++---------- 11 files changed, 636 insertions(+), 266 deletions(-) copy sdks/java/core/src/main/java/org/apache/beam/sdk/testing/{UsesStatefulParDo.java => UsesLoopingTimer.java} (88%) create mode 100644 sdks/java/harness/src/main/java/org/apache/beam/fn/harness/state/FnApiTimerBundleTracker.java