This is an automated email from the ASF dual-hosted git repository.
github-actions[bot] pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git
from aec0392a343 Revert previous workarounds and upgrade TFX stack to
1.21.0 (#39164)
add 74059db52cd Bump google.golang.org/grpc from 1.81.1 to 1.82.0 in /sdks
(#39186)
add f08c259a02e Bump google.golang.org/api from 0.286.0 to 0.287.0 in
/sdks (#39185)
add e87f50e3a9a Fix Python VarIntCoder OverflowError on uint64 values
(#39047)
add d0d754c635d Acknowledge messages asap in pubsub test (#39183)
add 8c0f0e02a82 Update Python Dependencies (#39139)
add 2f7d95d1cf9 [Gemini] Add batching support to Java Remote Inference
(#39067)
add 5f3fc19127e [Gemini] Add retry filter support to the Java Remote
RetryHandler (#39004)
add dac2848f4ae Upgrade TFX stack to 1.21.x and remove numpy/pandas bounds
add c2a62c12f94 Append timestamp to artifact_location and output_vocab
add 11cb59ed70c Upgrade tfx stack. Remove some upper bounds.
add 781ec5cdecf Consolidate the test requirements file to examples.
add 1567148726c Run one-hot test only
add b597f364dbd Remove ml_extra in one-hot load test
add 54783520416 Revert "Run one-hot test only"
add 1876512bb88 Minor edit on requirements.txt
add bc9937ade50 Fix typo
add 4a976d393c9 Merge pull request #39163 from apache/resolution-too-deep
add 00823b29fa4 Migrate MqttIO to HiveMQ Mqtt client (#39180)
add 8610459f7b8 [Gemini] Port client-side throttling to the Java SDK
(#39021)
add ca66eda1bc1 delta lake python/yaml (#39052)
add eed2511dcce Add "-Pjava21Home" to stage docker step (#39181)
No new revisions were added by this update.
Summary of changes:
...m_PostCommit_Python_Xlang_Messaging_Direct.json | 2 +-
.../beam_Inference_Python_Benchmarks_Dataflow.yml | 7 +-
.../beam_PostCommit_Yaml_Xlang_Direct.yml | 6 +-
.../beam_PreCommit_Xlang_Generated_Transforms.yml | 6 +-
.../workflows/beam_PreCommit_Yaml_Xlang_Direct.yml | 6 +-
.github/workflows/build_release_candidate.yml | 4 +-
...Dataflow_MLTransform_One_Hot_Encoding_Batch.txt | 2 +-
sdks/go.mod | 8 +-
sdks/go.sum | 16 +-
.../components/throttling/AdaptiveThrottler.java | 105 +++++++++++
.../components/throttling/ReactiveThrottler.java | 78 ++++++++
.../throttling/AdaptiveThrottlerTest.java | 107 +++++++++++
.../DeltaReadSchemaTransformProviderTest.java | 127 +++++++++++++
sdks/java/io/expansion-service/build.gradle | 1 +
sdks/java/io/google-cloud-platform/build.gradle | 1 +
.../sdk/io/gcp/datastore/AdaptiveThrottler.java | 111 -----------
.../beam/sdk/io/gcp/datastore/DatastoreV1.java | 1 +
.../io/gcp/datastore/AdaptiveThrottlerTest.java | 114 ------------
sdks/java/io/mqtt/build.gradle | 3 +-
.../java/org/apache/beam/sdk/io/mqtt/MqttIO.java | 182 ++++++++++--------
.../org/apache/beam/sdk/io/mqtt/MqttIOTest.java | 204 ++++++++++++---------
.../sdk/ml/inference/remote/RemoteInference.java | 33 ++--
.../beam/sdk/ml/inference/remote/RetryHandler.java | 27 ++-
.../ml/inference/remote/RemoteInferenceTest.java | 40 ++--
.../sdk/ml/inference/remote/RetryHandlerTest.java | 145 +++++++++++++++
sdks/python/apache_beam/coders/coder_impl.pxd | 1 -
sdks/python/apache_beam/coders/coder_impl.py | 34 +++-
.../apache_beam/coders/coders_test_common.py | 18 ++
.../mltransform_generate_vocab_requirements.txt | 10 +-
.../mltransform_one_hot_encoding_requirements.txt} | 16 +-
.../apache_beam/io/gcp/pubsub_integration_test.py | 20 +-
sdks/python/apache_beam/transforms/external.py | 1 +
sdks/python/apache_beam/transforms/managed.py | 4 +-
sdks/python/apache_beam/yaml/integration_tests.py | 22 +++
sdks/python/apache_beam/yaml/standard_io.yaml | 2 +
.../python/apache_beam/yaml/tests/delta.yaml | 24 ++-
sdks/python/apache_beam/yaml/yaml_io.py | 23 +++
.../container/ml/py310/base_image_requirements.txt | 34 ++--
.../container/ml/py310/gpu_image_requirements.txt | 44 ++---
.../container/ml/py311/base_image_requirements.txt | 34 ++--
.../container/ml/py311/gpu_image_requirements.txt | 44 ++---
.../container/ml/py312/base_image_requirements.txt | 34 ++--
.../container/ml/py312/gpu_image_requirements.txt | 44 ++---
.../container/ml/py313/base_image_requirements.txt | 34 ++--
.../container/py310/base_image_requirements.txt | 32 ++--
.../container/py311/base_image_requirements.txt | 32 ++--
.../container/py312/base_image_requirements.txt | 32 ++--
.../container/py313/base_image_requirements.txt | 32 ++--
.../container/py314/base_image_requirements.txt | 30 +--
sdks/standard_expansion_services.yaml | 1 +
50 files changed, 1230 insertions(+), 708 deletions(-)
create mode 100644
sdks/java/io/components/src/main/java/org/apache/beam/sdk/io/components/throttling/AdaptiveThrottler.java
create mode 100644
sdks/java/io/components/src/main/java/org/apache/beam/sdk/io/components/throttling/ReactiveThrottler.java
create mode 100644
sdks/java/io/components/src/test/java/org/apache/beam/sdk/io/components/throttling/AdaptiveThrottlerTest.java
create mode 100644
sdks/java/io/delta/src/test/java/org/apache/beam/sdk/io/delta/DeltaReadSchemaTransformProviderTest.java
delete mode 100644
sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/datastore/AdaptiveThrottler.java
delete mode 100644
sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/datastore/AdaptiveThrottlerTest.java
create mode 100644
sdks/java/ml/inference/remote/src/test/java/org/apache/beam/sdk/ml/inference/remote/RetryHandlerTest.java
rename
sdks/python/apache_beam/{ml/transforms/mltransform_tests_requirements.txt =>
examples/ml_transform/mltransform_one_hot_encoding_requirements.txt} (82%)
copy
.test-infra/kafka/strimzi/02-kafka-persistent/overlays/gke-internal-load-balanced/kustomization.yaml
=> sdks/python/apache_beam/yaml/tests/delta.yaml (66%)
