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 296421d0203 Merge pull request #36780: Adds SchemaFieldNumber
annotations to Iceberg classes that use the SchemaCoder
add 8e5b84527e1 Bump github.com/tetratelabs/wazero from 1.9.0 to 1.10.1 in
/sdks (#36797)
add 4eff1798314 fix CVE-2025-59250 (#36800)
add 4a59cb778e6 Fix Post Commit Transform Service (#36799)
add 83ebe731133 [1/3] sdks/python: refactor Milvus-related utilities as
preparation step for Milvus Sink I/O integration (#35708)
add addc06e8200 [Dataflow Streaming] Reuse ByteStringOutputStream buffers
in WindmillBag (#36742)
add 8c44a9ee80e Support custom id function in async_dofn (#36779)
No new revisions were added by this update.
Summary of changes:
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 2 +-
.../util/ThreadLocalByteStringOutputStream.java | 103 +++++
.../worker/windmill/state/WindmillBag.java | 25 +-
.../windmill/state/WindmillStateTagUtil.java | 58 +--
.../ThreadLocalByteStringOutputStreamTest.java | 68 ++++
sdks/go.mod | 2 +-
sdks/go.sum | 4 +-
sdks/java/io/iceberg/hive/build.gradle | 9 +-
.../transforms/elementwise/enrichment_test.py | 60 +--
.../apache_beam/ml/rag/enrichment/milvus_search.py | 133 ++-----
.../ml/rag/enrichment/milvus_search_it_test.py | 429 ++-------------------
.../ml/rag/ingestion/postgres_common.py | 56 +--
sdks/python/apache_beam/ml/rag/test_utils.py | 413 ++++++++++++++++++++
sdks/python/apache_beam/ml/rag/utils.py | 224 +++++++++++
sdks/python/apache_beam/transforms/async_dofn.py | 42 +-
.../apache_beam/transforms/async_dofn_test.py | 34 ++
sdks/python/expansion-service-container/Dockerfile | 3 +-
.../expansion-service-container/build.gradle | 4 +-
18 files changed, 1027 insertions(+), 642 deletions(-)
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/util/ThreadLocalByteStringOutputStream.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/util/ThreadLocalByteStringOutputStreamTest.java
create mode 100644 sdks/python/apache_beam/ml/rag/test_utils.py
create mode 100644 sdks/python/apache_beam/ml/rag/utils.py
