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(-)
