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 44500319cac Add sdf kafka poll latencies (#34275)
add cd5dddff1df remove private ipv6 check for direct path (#34368)
add 24c230510be Fix version on the master (#34371)
add 76dfe7807c1 Moving to 2.65.0-SNAPSHOT on master branch.
add a5281ddec07 Perform correct release version validation (#34378)
add 7dc3e383848 Add logic to fail if specified partitions do not exist in
the topic. (#34258)
add 51c02a3367b Include __init__.py which is customary for packages.
(#34362)
add 5eb1bcf688d Update verify_release_build.sh (#34382)
add 6a7460dda6a Update release-guide.md (#34383)
add 51cbc0af28b Created using Colab (#34251)
add 7e88d969b62 Update release-guide.md (#34386)
add 047f89637a1 Fix PostCommit TransformService Direct job (#34375)
add 3595a3303df Update CONTRIBUTING.md to point to code-change-guide
(#34384)
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 1 +
CONTRIBUTING.md | 63 +--
contributor-docs/code-change-guide.md | 13 +-
contributor-docs/release-guide.md | 4 -
.../alloydb_product_catalog_embeddings.ipynb | 498 ++++++++++++++++++++-
gradle.properties | 4 +-
release/src/main/scripts/set_version.sh | 4 +-
release/src/main/scripts/verify_release_build.sh | 2 +-
.../dataflow/worker/StreamingDataflowWorker.java | 27 +-
sdks/go/pkg/beam/core/core.go | 2 +-
.../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 10 +-
.../beam/sdk/io/kafka/KafkaUnboundedSource.java | 34 +-
.../sdk/io/kafka/WatchForKafkaTopicPartitions.java | 10 +-
.../org/apache/beam/sdk/io/kafka/KafkaIOIT.java | 98 ++++
.../runners/portability/expansion_service_main.py | 2 +-
sdks/python/apache_beam/version.py | 2 +-
sdks/typescript/package.json | 2 +-
.../sdks/python-pipeline-dependencies.md | 1 +
18 files changed, 679 insertions(+), 98 deletions(-)
