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 abdec1bcecd Bump github.com/nats-io/nats.go from 1.45.0 to 1.46.0 in
/sdks (#36312)
add 34aa17de6cd Allow users to pass service name for profiler for Java And
Go SDK (#35903)
add 970f6b26c5d [GSoC 25][Blog Post]: Beam ML Vector DB/Feature Store
Project (#36301)
add 292484f96a2 fix license script (#36328)
add bb340c2f66a further increase timeout (#36329)
add 4d87e040ac2 Add deterministic redistribute sharding for KafkaIO read.
(#36112)
add 449ab577d32 Update python SDK container image (#36341)
No new revisions were added by this update.
Summary of changes:
.../workflows/beam_Publish_Beam_SDK_Snapshots.yml | 2 +-
sdks/go/container/boot.go | 42 +++-
sdks/go/container/boot_test.go | 127 ++++++++---
sdks/java/container/boot.go | 88 +++++--
sdks/java/container/boot_test.go | 45 ++++
.../license_scripts/pull_licenses_java.py | 3 +-
.../apache/beam/sdk/transforms/Redistribute.java | 2 +-
.../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 53 ++++-
.../KafkaIOReadImplementationCompatibility.java | 6 +
.../beam/sdk/io/kafka/KafkaReadRedistribute.java | 124 ++++++++++
...KafkaIOReadImplementationCompatibilityTest.java | 6 +-
.../org/apache/beam/sdk/io/kafka/KafkaIOTest.java | 87 +++++--
.../sdk/io/kafka/KafkaReadRedistributeTest.java | 231 +++++++++++++++++++
.../sdk/io/kafka/upgrade/KafkaIOTranslation.java | 10 +
.../io/kafka/upgrade/KafkaIOTranslationTest.java | 1 +
.../apache_beam/runners/dataflow/internal/names.py | 2 +-
.../site/content/en/blog/gsoc-25-ml-connectors.md | 254 +++++++++++++++++++++
website/www/site/data/authors.yml | 4 +
18 files changed, 991 insertions(+), 96 deletions(-)
create mode 100644
sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaReadRedistribute.java
create mode 100644
sdks/java/io/kafka/src/test/java/org/apache/beam/sdk/io/kafka/KafkaReadRedistributeTest.java
create mode 100644 website/www/site/content/en/blog/gsoc-25-ml-connectors.md
