You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by re...@apache.org on 2022/04/09 23:08:49 UTC

[beam] branch master updated (f5a9712ef94 -> 5603bd310a6)

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 f5a9712ef94 Merge pull request #17329 from chamikaramj/re_raise_swallowed_exceptions
     add 5603bd310a6 Merge pull request #16928: [BEAM-11971] Re add reverted timer consistency PR

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 +++----
 .../runners/direct/TestStreamEvaluatorFactory.java |  13 +-
 .../beam/runners/direct/WatermarkManager.java      | 255 +++++++++------------
 .../apache/beam/runners/local/ExecutionDriver.java |   2 +-
 .../org/apache/beam/sdk/transforms/ParDoTest.java  |  39 +++-
 9 files changed, 262 insertions(+), 299 deletions(-)