This is an automated email from the ASF dual-hosted git repository.
kenn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit cdaae0a7fb63bd679823488f901603e135d6db67
Merge: f4d03d49713 8681ab9901d
Author: Kenneth Knowles <k...@apache.org>
AuthorDate: Wed Mar 20 18:28:21 2024 -0400
Merge pull request #30691: Revert #30425 "add a way for channels to be
closed manually"
.../google-cloud-dataflow-java/worker/build.gradle | 12 --
.../dataflow/worker/StreamingDataflowWorker.java | 11 +-
.../worker/windmill/WindmillConnection.java | 5 -
.../windmill/client/grpc/GrpcDispatcherClient.java | 4 +-
.../windmill/client/grpc/GrpcWindmillServer.java | 29 +---
.../client/grpc/StreamingEngineClient.java | 25 ++--
.../windmill/client/grpc/stubs/ChannelCache.java | 117 ----------------
.../grpc/stubs/ChannelCachingStubFactory.java | 38 ------
.../client/grpc/stubs/IsolationChannel.java | 2 +-
...Factory.java => RemoteWindmillStubFactory.java} | 38 +++---
.../client/grpc/stubs/WindmillChannelFactory.java | 2 +-
.../client/grpc/GrpcWindmillServerTest.java | 3 +-
.../client/grpc/StreamingEngineClientTest.java | 31 +++--
.../client/grpc/WindmillStreamSenderTest.java | 3 +-
.../client/grpc/stubs/ChannelCacheTest.java | 150 ---------------------
.../windmill/testing/FakeWindmillStubFactory.java | 27 ++--
.../budget/EvenGetWorkBudgetDistributorTest.java | 7 +-
17 files changed, 78 insertions(+), 426 deletions(-)
