This is an automated email from the ASF dual-hosted git repository.
kenn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 5a12de6 Merge pull request #12357: [BEAM-10411] Minor fix to
kafkataxi instructions
add 6d4684d [BEAM-10400] Fix race condition in DirectRunner watermark
update
add 101a493 [BEAM-10400] remove redundant state cleanup from
StatefulParDoEvaluatorFactory
add 639cb75 Merge pull request #12155: [BEAM-10400] Fix race condition in
DirectRunner watermark update
No new revisions were added by this update.
Summary of changes:
.../beam/runners/direct/EvaluationContext.java | 21 +++-
.../beam/runners/direct/QuiescenceDriver.java | 43 +++++--
.../direct/StatefulParDoEvaluatorFactory.java | 110 +----------------
.../beam/runners/direct/WatermarkManager.java | 20 +++-
.../direct/StatefulParDoEvaluatorFactoryTest.java | 131 ---------------------
5 files changed, 70 insertions(+), 255 deletions(-)
