This is an automated email from the ASF dual-hosted git repository.
github-actions[bot] pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git
from f29d9af139a init (#39025)
add 447899e46e9 [mqtt] Add Python Xlang Messaging PostCommit with MQTT
integration tests (#38966)
add cedfd0bb3e8 [ReduceFnRunner] Fix Prefetches (#39082)
add c3d9a731b42 [Dataflow Streaming] Increase stuck commit invalidation
timeout to 1 hour (#39083)
add 24e9ed4e0e9 Bump actions/cache from 4 to 6 (#39081)
add f7f0e1655d5 Bump actions/checkout from 6 to 7 (#39080)
add 0165344ab13 Add UnboundedCountingSource::to for bounded reads from an
UnboundedCountingSource (#39084)
add f33feafb2b2 [Dataflow Java Streaming] Add a timeout to how long
commits will retry to the service. (#39085)
add 857dfc9a875 [mqtt] Fix streaming xlang IT failing the Messaging
PostCommit (#39088)
add 0802263e48e Add a github workflow to publish vllm image. (#39089)
add 8e4ea736213 [Python] Optimize BigQuery copy jobs in file loads using
multi-source copy (#38983)
add 5afb93c8c09 [OpenTelemetry] Turn off gcp otel auth extension by
default. (#38940)
add 4e9e483a51a Fix Flink XVR for Flink 2
add 49fd8745223 Fix Go Flink VR conf path
add 16acfa8a2c6 Update CHANGES.md and website
add f13ccf7afbe Merge pull request #39077 from Abacn/fix-flink-xvr
add 9e28c9d2150 Disable flaky SDF finalization tests
add 6095fd0de62 Merge pull request #39092 from
arunpandianp/disablesdffinalization
add 70b72adffee Fix Install xmllint
add 0aa808dba09 Merge pull request #39094 from apache/cut-release-branch
add cad9f1ebe76 Moving to 2.76.0-SNAPSHOT on master branch.
add beeb715739f Update beam-master (#39095)
add c531095fc40 [GSOC 2026] Adding logic to validate and generate an error
if there are key… (#38992)
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 1 +
.../trigger_files/beam_PostCommit_Go_VR_Flink.json | 2 +-
..._PostCommit_Python_Xlang_Messaging_Direct.json} | 2 +-
.../trigger_files/beam_PostCommit_XVR_Flink.json | 2 +-
.../trigger_files/beam_PostCommit_XVR_Samza.json | 1 -
.github/workflows/README.md | 2 +
...m_PostCommit_Python_Xlang_Messaging_Direct.yml} | 30 +--
...Jobs.yml => beam_Publish_Python_VLLM_Image.yml} | 71 +++---
.github/workflows/cut_release_branch.yml | 5 +-
.github/workflows/playground_frontend_test.yml | 2 +-
.github/workflows/tour_of_beam_frontend_test.yml | 2 +-
CHANGES.md | 4 +-
gradle.properties | 4 +-
infra/enforcement/account_keys.py | 103 ++++++--
infra/enforcement/sending.py | 105 +++++++-
.../apache/beam/runners/core/ReduceFnRunner.java | 3 +-
runners/flink/job-server/flink_job_server.gradle | 20 +-
runners/google-cloud-dataflow-java/build.gradle | 7 +-
.../options/DataflowStreamingPipelineOptions.java | 19 +-
.../dataflow/worker/StreamingDataflowWorker.java | 8 +
.../windmill/client/grpc/GrpcCommitWorkStream.java | 94 ++++++--
.../client/grpc/GrpcWindmillStreamFactory.java | 10 +
.../client/grpc/GrpcCommitWorkStreamTest.java | 82 +++++++
scripts/beam-sql.sh | 2 +-
sdks/go/pkg/beam/core/core.go | 2 +-
sdks/go/test/build.gradle | 2 +-
.../org/apache/beam/sdk/io/CountingSource.java | 40 ++-
.../org/apache/beam/sdk/io/CountingSourceTest.java | 36 +++
.../java/org/apache/beam/fn/harness/FnHarness.java | 6 +
.../io/external/xlang_mqttio_it_test.py | 268 +++++++++++++++++++++
.../apache_beam/io/gcp/bigquery_file_loads.py | 162 ++++++-------
.../apache_beam/io/gcp/bigquery_file_loads_test.py | 205 ++++++++++++----
sdks/python/apache_beam/io/gcp/bigquery_tools.py | 18 +-
sdks/python/apache_beam/version.py | 2 +-
sdks/python/pytest.ini | 1 +
sdks/python/test-suites/direct/build.gradle | 6 +
sdks/python/test-suites/xlang/build.gradle | 8 +-
sdks/typescript/package.json | 2 +-
.../site/content/en/documentation/runners/flink.md | 4 +-
39 files changed, 1082 insertions(+), 261 deletions(-)
copy .github/trigger_files/{beam_PostCommit_SQL.json =>
beam_PostCommit_Python_Xlang_Messaging_Direct.json} (82%)
delete mode 100644 .github/trigger_files/beam_PostCommit_XVR_Samza.json
copy .github/workflows/{beam_PostCommit_Python_MongoDBIO_IT.yml =>
beam_PostCommit_Python_Xlang_Messaging_Direct.yml} (82%)
copy .github/workflows/{beam_CancelStaleDataflowJobs.yml =>
beam_Publish_Python_VLLM_Image.yml} (55%)
create mode 100644 sdks/python/apache_beam/io/external/xlang_mqttio_it_test.py
