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 fcd3fcc [BEAM-12260] Java - Backport Firestore connector's ramp-up
throttling to Datastore connector (#14713)
add a4411be [BEAM-12144] Change windmill grpc streams to reevaluate
isReady and throw an exception if the stream is not finished after the deadline
has passed. Also avoid blocking on the first message as it is performed under
the StreamPool sychronized block.
add 4ed18ea Merge pull request #14714: [BEAM-12144] Change windmill grpc
streams to reevaluate isReady
No new revisions were added by this update.
Summary of changes:
.../worker/windmill/DirectStreamObserver.java | 62 +++++++++++++++++++---
.../worker/windmill/GrpcWindmillServer.java | 3 +-
.../worker/windmill/StreamObserverFactory.java | 12 +++--
3 files changed, 65 insertions(+), 12 deletions(-)
