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 930d14abc99 Fix sigint handler for StopOnExitJobServer (#34748)
add ca64fcf8b67 Fix handling of collections.Counter types (#34706)
add cefc9a20144 Add option to create metedata filter with function.
(#34754)
add fb415f7b55b Enable cloudpickle by default (#34695)
add 0dd5dd327d7 Update schedule cron time (#34765)
add b9fa49a9827 Use Java 17 for Debezium IO #34747 (#34751)
No new revisions were added by this update.
Summary of changes:
.github/trigger_files/beam_PostCommit_Python.json | 2 +-
...tCommit_Python_ValidatesContainer_Dataflow.json | 2 +-
.../beam_PostCommit_Python_Xlang_Gcp_Dataflow.json | 2 +-
.../beam_PostCommit_Python_Xlang_Gcp_Direct.json | 2 +-
.../beam_PostCommit_Python_Xlang_IO_Direct.json | 2 +-
...PostCommit_Java_ValidatesRunner_Flink_Java8.yml | 2 +-
.../beam_PreCommit_Java_Debezium_IO_Direct.yml | 10 +-
sdks/python/apache_beam/internal/pickler.py | 4 +-
sdks/python/apache_beam/internal/pickler_test.py | 104 +++++++-
.../ml/rag/enrichment/bigquery_vector_search.py | 33 ++-
.../enrichment/bigquery_vector_search_it_test.py | 292 +++++++++++++++++----
sdks/python/apache_beam/pipeline.py | 15 +-
sdks/python/apache_beam/pipeline_test.py | 34 ++-
.../runners/dataflow/dataflow_runner.py | 3 +
.../runners/direct/direct_runner_test.py | 24 +-
sdks/python/apache_beam/runners/runner.py | 4 +
.../typehints/native_type_compatibility.py | 8 +
.../typehints/native_type_compatibility_test.py | 4 +
18 files changed, 455 insertions(+), 92 deletions(-)
