This is an automated email from the ASF dual-hosted git repository.

lcwik pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from 7e2b637  Merge pull request #16752: [BEAM-13147] Avoid nullness issue 
during init of AwsModule (AWS Sdk v2)
     add 98e5fc5  [BEAM-11971] Revert "Fix timer consistency in direct runner" 
(#16748)

No new revisions were added by this update.

Summary of changes:
 .../apache/beam/runners/core/TimerInternals.java   |  17 +-
 .../beam/runners/direct/DirectTimerInternals.java  |  72 +++---
 .../direct/ExecutorServiceParallelExecutor.java    |   2 +-
 .../beam/runners/direct/QuiescenceDriver.java      |  78 +++----
 .../direct/StatefulParDoEvaluatorFactory.java      |  83 +++----
 .../beam/runners/direct/WatermarkManager.java      | 250 ++++++++++++---------
 .../apache/beam/runners/local/ExecutionDriver.java |   2 +-
 .../org/apache/beam/sdk/transforms/ParDoTest.java  |  10 +-
 8 files changed, 282 insertions(+), 232 deletions(-)

Reply via email to