This is an automated email from the ASF dual-hosted git repository.
reuvenlax pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit c581b4dc6bd33360af890c9342e5239b8fcc7561
Merge: 505b5b723b0 9e7cc7cfd76
Author: Reuven Lax <re...@google.com>
AuthorDate: Wed Jul 27 16:09:35 2022 -0700
Merge pull request #22461: Fixes #22438. Ensure that WindmillStateReader
completes all batched read futures on exceptions
.../dataflow/worker/WindmillStateReader.java | 109 ++++++++------
.../dataflow/worker/WindmillStateReaderTest.java | 161 ++++++++++++++++++++-
2 files changed, 222 insertions(+), 48 deletions(-)
