This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch nightly-refs/heads/master in repository https://gitbox.apache.org/repos/asf/beam.git
from 389e1067c9d Disable unsupported custom window type test on samza and spark. (#30680) add 81cb194f8d1 Bump golang.org/x/oauth2 from 0.17.0 to 0.18.0 in /sdks (#30685) add 8206d8976d5 Bump github.com/docker/docker in /sdks (#30684) add a9ce7700ade Send email when BQ early rollout workflow fails (#30694) add f4d03d49713 Minimize scope of expensive lock (#30679) add 8681ab9901d Revert "Cache and close windmill grpc channels (#30425)" add cdaae0a7fb6 Merge pull request #30691: Revert #30425 "add a way for channels to be closed manually" add 4a3b6c55fd8 Use unique GCS object path (#30690) add 8955124219c Add BigTableIO Stress test (#30630) No new revisions were added by this update. Summary of changes: .../beam_PostCommit_Java_BigQueryEarlyRollout.yml | 21 +- it/google-cloud-platform/build.gradle | 5 +- .../org/apache/beam/it/gcp/IOLoadTestBase.java | 34 ++ .../org/apache/beam/it/gcp/IOStressTestBase.java | 123 +++++++ .../apache/beam/it/gcp/bigquery/BigQueryIOST.java | 105 +----- .../apache/beam/it/gcp/bigtable/BigTableIOST.java | 389 +++++++++++++++++++++ it/kafka/build.gradle | 4 +- .../java/org/apache/beam/it/kafka/KafkaIOST.java | 156 ++------- .../src/main/groovy/MobileGamingCommands.groovy | 5 +- .../main/groovy/mobilegaming-java-dataflow.groovy | 5 +- .../main/groovy/mobilegaming-java-direct.groovy | 5 +- .../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 +- sdks/go.mod | 6 +- sdks/go.sum | 12 +- .../resources/beam/checkstyle/suppressions.xml | 1 + .../apache_beam/runners/worker/sdk_worker.py | 14 +- 32 files changed, 706 insertions(+), 683 deletions(-) create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/IOStressTestBase.java create mode 100644 it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/bigtable/BigTableIOST.java delete mode 100644 runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/stubs/ChannelCache.java delete mode 100644 runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/stubs/ChannelCachingStubFactory.java rename runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/stubs/{ChannelCachingRemoteStubFactory.java => RemoteWindmillStubFactory.java} (67%) delete mode 100644 runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/windmill/client/grpc/stubs/ChannelCacheTest.java