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 444e10d29e0 Kafka adaptive timeout implementation to handle empty
topic cases (#29400)
add 074a01ccfcf Update the About ML page and create a redirect from the
Python page (#29509)
add 99314816b0f Add package-info to fix checkstyle validation (#29521)
add e863d919a32 Improve actionability on IT errors (with Dataflow job URL)
(#29520)
add 09a2cfcc2b2 Bump grpc_version dependency (#29511)
add 23b1fe96128 add canonical link into javadocs when running post commit
(#29475)
add 9ee6a012e03 Attach exact cause in RuntimeException raised (#29470)
add 00d5863551c add canonical link into javadocs when releasing javadoc
(#29473)
add 1e06d882bdd [RRIO] [Throttle] [Cache] Implement Throttle and Cache
using an external resource. (#29401)
add 200aa46b2a7 [prism] Fix downstream side input computations. (#29439)
add 40a9882343c Update Java dependency management page (#29513)
add 2a20b097262 Close the gRPC channel started for the expansion service
(#29524)
No new revisions were added by this update.
Summary of changes:
.github/workflows/README.md | 11 +
.github/workflows/beam_PostCommit_Javadoc.yml | 5 +
.github/workflows/build_release_candidate.yml | 5 +
.../configmap.yaml | 30 ++
.../deployment.yaml | 27 ++
.../kustomization.yaml | 34 ++
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 2 +-
.../apache/beam/it/conditions/ConditionCheck.java | 2 +-
.../it/gcp/dataflow/AbstractPipelineLauncher.java | 5 +-
sdks/go/pkg/beam/io/fileio/read_test.go | 16 +-
.../prism/internal/engine/elementmanager.go | 39 +-
sdks/go/pkg/beam/runners/prism/internal/execute.go | 29 +-
.../beam/runners/prism/internal/handlecombine.go | 6 +-
.../runners/prism/internal/handlecombine_test.go | 212 +++++++++
.../pkg/beam/runners/prism/internal/handlepardo.go | 2 +-
.../pkg/beam/runners/prism/internal/preprocess.go | 180 ++++----
.../beam/runners/prism/internal/preprocess_test.go | 504 ++++++++++++++++++++-
sdks/go/pkg/beam/runners/prism/internal/stage.go | 18 +-
sdks/go/pkg/beam/util/pubsubx/pubsub_test.go | 4 +
.../java/org/apache/beam/agent/package-info.java | 23 +
.../bigquery/StorageApiWriteUnshardedRecords.java | 12 +-
sdks/java/io/rrio/build.gradle | 1 +
.../org/apache/beam/io/requestresponse/Cache.java | 239 ++++++++++
.../apache/beam/io/requestresponse/CacheRead.java | 121 -----
.../apache/beam/io/requestresponse/CacheWrite.java | 119 -----
.../org/apache/beam/io/requestresponse/Call.java | 39 +-
.../org/apache/beam/io/requestresponse/Quota.java | 70 +++
.../beam/io/requestresponse/RedisClient.java | 10 +
.../beam/io/requestresponse/ThrottleDequeue.java | 101 -----
.../beam/io/requestresponse/ThrottleEnqueue.java | 61 ---
.../io/requestresponse/ThrottleRefreshQuota.java | 55 ---
.../ThrottleWithExternalResource.java | 418 +++++++++++++++++
.../apache/beam/io/requestresponse/CacheIT.java | 120 +++++
.../apache/beam/io/requestresponse/CacheTest.java | 132 ++++++
.../apache/beam/io/requestresponse/CallTest.java | 112 ++++-
...java => EchoGRPCCallerWithSetupTeardownIT.java} | 14 +-
...HTTPCallerTestIT.java => EchoHTTPCallerIT.java} | 18 +-
.../beam/io/requestresponse/EchoITOptions.java | 7 +-
.../beam/io/requestresponse/EchoRequestCoder.java | 44 ++
.../{RedisClientTestIT.java => RedisClientIT.java} | 24 +-
.../ThrottleWithExternalResourceIT.java | 186 ++++++++
.../ThrottleWithExternalResourceTest.java | 77 ++++
sdks/python/apache_beam/utils/subprocess_server.py | 15 +-
.../site/content/en/documentation/ml/about-ml.md | 341 +++++++++++++-
.../en/documentation/sdks/java-dependencies.md | 138 +++++-
.../documentation/sdks/python-machine-learning.md | 435 ------------------
46 files changed, 2955 insertions(+), 1108 deletions(-)
create mode 100644
.test-infra/mock-apis/infrastructure/kubernetes/refresher/overlays/echo-ThrottleWithExternalResourceTestIT-10-per-1s-quota/configmap.yaml
create mode 100644
.test-infra/mock-apis/infrastructure/kubernetes/refresher/overlays/echo-ThrottleWithExternalResourceTestIT-10-per-1s-quota/deployment.yaml
create mode 100644
.test-infra/mock-apis/infrastructure/kubernetes/refresher/overlays/echo-ThrottleWithExternalResourceTestIT-10-per-1s-quota/kustomization.yaml
create mode 100644
sdks/go/pkg/beam/runners/prism/internal/handlecombine_test.go
create mode 100644
sdks/java/container/agent/src/main/java/org/apache/beam/agent/package-info.java
create mode 100644
sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/Cache.java
delete mode 100644
sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/CacheRead.java
delete mode 100644
sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/CacheWrite.java
create mode 100644
sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/Quota.java
delete mode 100644
sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/ThrottleDequeue.java
delete mode 100644
sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/ThrottleEnqueue.java
delete mode 100644
sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/ThrottleRefreshQuota.java
create mode 100644
sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/ThrottleWithExternalResource.java
create mode 100644
sdks/java/io/rrio/src/test/java/org/apache/beam/io/requestresponse/CacheIT.java
create mode 100644
sdks/java/io/rrio/src/test/java/org/apache/beam/io/requestresponse/CacheTest.java
rename
sdks/java/io/rrio/src/test/java/org/apache/beam/io/requestresponse/{EchoGRPCCallerWithSetupTeardownTestIT.java
=> EchoGRPCCallerWithSetupTeardownIT.java} (91%)
rename
sdks/java/io/rrio/src/test/java/org/apache/beam/io/requestresponse/{EchoHTTPCallerTestIT.java
=> EchoHTTPCallerIT.java} (87%)
create mode 100644
sdks/java/io/rrio/src/test/java/org/apache/beam/io/requestresponse/EchoRequestCoder.java
rename
sdks/java/io/rrio/src/test/java/org/apache/beam/io/requestresponse/{RedisClientTestIT.java
=> RedisClientIT.java} (89%)
create mode 100644
sdks/java/io/rrio/src/test/java/org/apache/beam/io/requestresponse/ThrottleWithExternalResourceIT.java
create mode 100644
sdks/java/io/rrio/src/test/java/org/apache/beam/io/requestresponse/ThrottleWithExternalResourceTest.java
delete mode 100644
website/www/site/content/en/documentation/sdks/python-machine-learning.md
