This is an automated email from the ASF dual-hosted git repository.
scwhittle pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from e9202abb7ad Merge pull request #30161 [YAML] Add documentation to Beam
site.
add 2d08b32e674 Add options giving more isolation between grpc streaming
rpcs. (#30233)
No new revisions were added by this update.
Summary of changes:
.../google-cloud-dataflow-java/worker/build.gradle | 3 +-
.../worker/MetricTrackingWindmillServerStub.java | 81 ++++-
.../dataflow/worker/StreamingDataflowWorker.java | 7 +-
.../options/StreamingDataflowWorkerOptions.java | 19 +
.../windmill/client/grpc/GrpcWindmillServer.java | 3 +-
.../client/grpc/stubs/IsolationChannel.java | 249 +++++++++++++
.../client/grpc/stubs/WindmillChannelFactory.java | 8 +-
.../client/grpc/stubs/WindmillStubFactory.java | 17 +-
.../client/grpc/stubs/IsolationChannelTest.java | 403 +++++++++++++++++++++
9 files changed, 756 insertions(+), 34 deletions(-)
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/stubs/IsolationChannel.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/stubs/IsolationChannelTest.java
