This is an automated email from the ASF dual-hosted git repository.
lcwik pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 7497a2c Merge pull request #15891: [BEAM-13187] Set filesToStage
after full jar resolution.
add e4f8f4b [BEAM-3811] Code clean-up of the CancelleableQueue to not
throw InterruptedException on cancel/reset since we are never stuck in a loop
here or waiting on a signal.
add 5e00300 [BEAM-3811] Code clean-up of the CancelleableQueue to not
throw InterruptedException on cancel/reset since we are never stuck in a loop
here or waiting on a signal.
No new revisions were added by this update.
Summary of changes:
.../org/apache/beam/sdk/fn/CancellableQueue.java | 24 ++---
.../sdk/fn/stream/BufferingStreamObserver.java | 116 ++++++++-------------
2 files changed, 53 insertions(+), 87 deletions(-)
