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 50f33cd786d [Python] Check feature store existence at pipeline construction time (#30668) add c1c255a0a43 Cache and close windmill grpc channels (#30425) No new revisions were added by this update. Summary of changes: .../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 ++++++++++++++++ ...y.java => ChannelCachingRemoteStubFactory.java} | 38 +++--- ...Factory.java => ChannelCachingStubFactory.java} | 24 ++-- .../client/grpc/stubs/IsolationChannel.java | 2 +- .../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, 403 insertions(+), 87 deletions(-) create mode 100644 runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/stubs/ChannelCache.java rename runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/stubs/{RemoteWindmillStubFactory.java => ChannelCachingRemoteStubFactory.java} (67%) copy runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/stubs/{WindmillStubFactory.java => ChannelCachingStubFactory.java} (58%) create mode 100644 runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/stubs/ChannelCacheTest.java