beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From github-...@apache.org
Subject [beam] tag nightly-master updated (dce846b -> 7b54b0b)
Date Tue, 03 Aug 2021 03:25:51 GMT
This is an automated email from the ASF dual-hosted git repository.

github-bot pushed a change to tag nightly-master
in repository https://gitbox.apache.org/repos/asf/beam.git.


*** WARNING: tag nightly-master was modified! ***

    from dce846b  (commit)
      to 7b54b0b  (commit)
    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

Mime
View raw message