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
