You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by sc...@apache.org on 2024/03/19 14:41:00 UTC
(beam) branch master updated (50f33cd786d -> c1c255a0a43)

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