This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/pip/sdks/python/container/ml/py312/aiohttp-3.13.3
in repository https://gitbox.apache.org/repos/asf/beam.git
discard 37567d6abf3 Bump aiohttp from 3.13.2 to 3.13.3 in
/sdks/python/container/ml/py312
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)
add 9d2abcfa2ba Bump numpy versions (#37238)
add 4777bef1268 Add nanosecond timestamp support for Storage write when
writing GenericRecords and Beam Rows (#37235)
add 8a9011382e5 Moving to 2.72.0-SNAPSHOT on master branch.
add 3c3e2024d98 add some debug checks in test case and remove an extra
line (#37237)
add fb3f48c8cb4 Bump aiohttp from 3.13.2 to 3.13.3 in
/sdks/python/container/ml/py312
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (37567d6abf3)
\
N -- N -- N
refs/heads/dependabot/pip/sdks/python/container/ml/py312/aiohttp-3.13.3
(fb3f48c8cb4)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 1 +
.github/workflows/README.md | 1 +
...ml => beam_PostCommit_Java_PVR_Flink_Batch.yml} | 21 +-
CHANGES.md | 3 +-
gradle.properties | 4 +-
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
scripts/beam-sql.sh | 2 +-
sdks/go.mod | 2 +-
sdks/go.sum | 4 +-
sdks/go/pkg/beam/core/core.go | 2 +-
.../AvroGenericRecordToStorageApiProto.java | 104 ++++++---
.../io/gcp/bigquery/BeamRowToStorageApiProto.java | 49 ++++-
.../sdk/io/gcp/bigquery/BigQueryAvroUtils.java | 2 +-
.../beam/sdk/io/gcp/bigquery/BigQueryUtils.java | 12 +-
.../AvroGenericRecordToStorageApiProtoTest.java | 120 +++++++++++
.../gcp/bigquery/BeamRowToStorageApiProtoTest.java | 62 +++++-
.../sdk/io/gcp/bigquery/BigQueryAvroUtilsTest.java | 3 +-
.../io/gcp/bigquery/BigQueryTimestampPicosIT.java | 112 ++++++++++
.../sdk/io/gcp/bigquery/BigQueryUtilsTest.java | 48 +++--
sdks/python/apache_beam/dataframe/io.py | 1 -
.../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/version.py | 2 +-
sdks/python/apache_beam/yaml/yaml_io.py | 5 +-
.../python/apache_beam/yaml/yaml_transform_test.py | 12 +-
.../container/py312/base_image_requirements.txt | 2 +-
sdks/python/pyproject.toml | 2 +-
sdks/python/setup.py | 2 +-
sdks/typescript/package.json | 2 +-
41 files changed, 954 insertions(+), 193 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%)
