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 32a0f09 [BEAM-13757] adds pane observation in DoFn (#16629)
add 8ea77f9 Fix timer consistency in direct runner
add 6814a06 Merge pull request #16650:[BEAM-11971] Fix directrunner timer
consistency
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, 232 insertions(+), 282 deletions(-)
