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 2ed225f3c4d Updates Beam master container tags for Dataflow (#38766)
add 98ca01f415c [Dataflow Streaming] Prepare BoundedQueueExecutor for
MultiKey bundles (#38592)
add c315ceacb5c Fix truncating file handle (#38425)
add 54accc32caf js2py to quickjs (#38473)
add fd0c3e48218 Migrate to Google Cloud Dataflow Client (#37639)
add 4f2d8c0ec2d Adding release-2.74.0-postrelease to protected branches in
.asf.yaml
add 8c93ab0efae Update managed-io.md for release 2.74.0-RC1. (#38527)
add ef3d8cccb43 Update Beam website to release 2.74.0 (#38536)
add 13a46356a02 Update Python Dependencies (#38775)
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 1 +
.github/trigger_files/beam_PostCommit_Python.json | 2 +-
...PostCommit_Python_ValidatesRunner_Dataflow.json | 2 +-
CHANGES.md | 6 +-
.../streaming/BoundedQueueExecutorWorkHandle.java | 6 +-
.../dataflow/worker/streaming/ExecutableWork.java | 51 +-
.../dataflow/worker/util/BoundedQueueExecutor.java | 166 +-
.../ExceptionUtils.java} | 27 +-
.../work/processing/StreamingCommitFinalizer.java | 2 +-
.../work/processing/StreamingWorkScheduler.java | 18 +-
.../worker/StreamingDataflowWorkerTest.java | 4 +-
.../worker/streaming/ActiveWorkStateTest.java | 4 +-
.../streaming/ComputationStateCacheTest.java | 2 +-
.../worker/util/BoundedQueueExecutorTest.java | 107 +-
.../failures/WorkFailureProcessorTest.java | 4 +-
.../work/refresh/ActiveWorkRefresherTest.java | 4 +-
sdks/python/apache_beam/dataframe/io.py | 15 +-
sdks/python/apache_beam/dataframe/io_test.py | 45 +
.../runners/dataflow/dataflow_metrics.py | 63 +-
.../runners/dataflow/dataflow_metrics_test.py | 314 +-
.../runners/dataflow/dataflow_runner.py | 56 +-
.../runners/dataflow/dataflow_runner_test.py | 39 +-
.../runners/dataflow/internal/apiclient.py | 517 +-
.../runners/dataflow/internal/apiclient_test.py | 292 +-
.../dataflow/internal/clients/dataflow/__init__.py | 34 -
.../clients/dataflow/dataflow_v1b3_client.py | 1318 ----
.../clients/dataflow/dataflow_v1b3_messages.py | 8077 --------------------
.../internal/clients/dataflow/message_matchers.py | 118 -
.../clients/dataflow/message_matchers_test.py | 74 -
sdks/python/apache_beam/yaml/readme_test.py | 16 +-
sdks/python/apache_beam/yaml/yaml_mapping.py | 171 +-
sdks/python/apache_beam/yaml/yaml_udf_test.py | 119 +-
.../container/ml/py310/base_image_requirements.txt | 31 +-
.../container/ml/py310/gpu_image_requirements.txt | 51 +-
.../container/ml/py311/base_image_requirements.txt | 35 +-
.../container/ml/py311/gpu_image_requirements.txt | 55 +-
.../container/ml/py312/base_image_requirements.txt | 32 +-
.../container/ml/py312/gpu_image_requirements.txt | 55 +-
.../container/ml/py313/base_image_requirements.txt | 32 +-
.../container/py310/base_image_requirements.txt | 31 +-
.../container/py311/base_image_requirements.txt | 35 +-
.../container/py312/base_image_requirements.txt | 32 +-
.../container/py313/base_image_requirements.txt | 32 +-
.../container/py314/base_image_requirements.txt | 30 +-
sdks/python/setup.py | 4 +-
website/www/site/config.toml | 2 +-
website/www/site/content/en/blog/beam-2.74.0.md | 70 +
.../site/content/en/documentation/io/managed-io.md | 551 +-
.../www/site/content/en/get-started/downloads.md | 22 +-
49 files changed, 1723 insertions(+), 11051 deletions(-)
copy
it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/dlp/package-info.java
=>
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/BoundedQueueExecutorWorkHandle.java
(78%)
copy
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/{streaming/config/StreamingGlobalConfigHandle.java
=> util/ExceptionUtils.java} (53%)
delete mode 100644
sdks/python/apache_beam/runners/dataflow/internal/clients/dataflow/__init__.py
delete mode 100644
sdks/python/apache_beam/runners/dataflow/internal/clients/dataflow/dataflow_v1b3_client.py
delete mode 100644
sdks/python/apache_beam/runners/dataflow/internal/clients/dataflow/dataflow_v1b3_messages.py
delete mode 100644
sdks/python/apache_beam/runners/dataflow/internal/clients/dataflow/message_matchers.py
delete mode 100644
sdks/python/apache_beam/runners/dataflow/internal/clients/dataflow/message_matchers_test.py
create mode 100644 website/www/site/content/en/blog/beam-2.74.0.md
