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 19f9eb06fb5 [yaml] - add multi-line windowing json support (#37174)
add 207f9d0e04d Update names.py (#37222)
add 16996bbb480 docs: fix typo and clarify BigQuery error handling method
requirements (#37215)
add 716ce6a3d4c Bump aiohttp from 3.13.2 to 3.13.3 in
/sdks/python/container/py312 (#37229)
add 34b8eea96f8 Introduce Python Wordcount with Rust Wrapped Functions
(#37234)
add bf5c0db53c1 Bump github.com/tetratelabs/wazero from 1.10.1 to 1.11.0
in /sdks (#37160)
add 33195172e78 Fix CHANGES.md format (#37236)
add d55cf588e58 Flink 2 support prerequisites (#37133)
No new revisions were added by this update.
Summary of changes:
.github/workflows/README.md | 1 +
...ml => beam_PostCommit_Java_PVR_Flink_Batch.yml} | 21 +-
CHANGES.md | 3 +-
runners/flink/flink_runner.gradle | 125 +++++++----
.../flink_job_server_container.gradle | 10 +-
runners/flink/job-server/flink_job_server.gradle | 31 ++-
.../beam/runners/flink/FlinkPipelineRunner.java | 4 +-
.../wrappers/streaming/DoFnOperator.java | 0
.../flink/streaming/MemoryStateBackendWrapper.java | 0
.../runners/flink/streaming/StreamSources.java | 0
sdks/go.mod | 2 +-
sdks/go.sum | 4 +-
.../apache_beam/examples/wordcount_rust/README.md | 51 +++++
.../wordcount_rust/requirements.txt} | 3 +-
.../wordcount_rust/word_processing/Cargo.lock | 234 +++++++++++++++++++++
.../wordcount_rust/word_processing/Cargo.toml | 20 +-
.../wordcount_rust/word_processing/pyproject.toml} | 16 +-
.../wordcount_rust/word_processing/src/lib.rs} | 31 ++-
.../wordcount_rust.py} | 40 +---
.../apache_beam/runners/dataflow/internal/names.py | 2 +-
sdks/python/apache_beam/yaml/yaml_io.py | 5 +-
.../container/py312/base_image_requirements.txt | 2 +-
22 files changed, 473 insertions(+), 132 deletions(-)
copy .github/workflows/{beam_PreCommit_Java_PVR_Flink_Batch.yml =>
beam_PostCommit_Java_PVR_Flink_Batch.yml} (85%)
rename runners/flink/{1.17 =>
}/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming/DoFnOperator.java
(100%)
rename runners/flink/{1.17 =>
}/src/test/java/org/apache/beam/runners/flink/streaming/MemoryStateBackendWrapper.java
(100%)
rename runners/flink/{1.17 =>
}/src/test/java/org/apache/beam/runners/flink/streaming/StreamSources.java
(100%)
create mode 100644 sdks/python/apache_beam/examples/wordcount_rust/README.md
copy
sdks/python/apache_beam/{transforms/enrichment_handlers/feast_tests_requirements.txt
=> examples/wordcount_rust/requirements.txt} (96%)
create mode 100644
sdks/python/apache_beam/examples/wordcount_rust/word_processing/Cargo.lock
copy
.test-infra/kafka/strimzi/02-kafka-persistent/overlays/gke-internal-load-balanced/kustomization.yaml
=> sdks/python/apache_beam/examples/wordcount_rust/word_processing/Cargo.toml
(74%)
copy sdks/python/apache_beam/{io/gcp/pubsublite/__init__.py =>
examples/wordcount_rust/word_processing/pyproject.toml} (69%)
copy sdks/{go/pkg/beam/doc.go =>
python/apache_beam/examples/wordcount_rust/word_processing/src/lib.rs} (58%)
copy sdks/python/apache_beam/examples/{wordcount.py =>
wordcount_rust/wordcount_rust.py} (75%)
