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 1318bfe2039 Fix runner compatibility matrix (#39682)
add 559d22c498b fix ensurepip bundled pip cleanup for Python 3.12+
containers (#39683)
add d97899b7ab8 Add Sample.Any to the Python SDK to match Java's
Sample.any (#39442)
add 0b40089ffd1 Fix mobile gaming release validation background process
cleanup for Java 21 compatibility (#39658)
add d6a865d2e4d Persist credentials for build_release_candidate.yml
add f0da6f36657 Enable OpenTelemetry stiching with Logs for Dataflow
worker, both for direct logging and file based (#39625)
add 8d24582beab (IcebergIO) document writeProperties param more clearly
(#39645)
add 367f46d4014 [Python] Create temporary dataset with a 24 hour ttl.
(#39615)
add 4731dbc5a38 Fix RequestResponseIO parseAndThrow to preserve retryable
exception types (#37342)
add c91aa1c1d89 feat: add MongoDB driver handshake metadata for Java-based
client connections (#39504)
add eab1bceed4f Bump dorny/paths-filter from 4.0.1 to 4.0.3 (#39693)
add f55c10b33e5 Pin grpcio-tools==1.78.0 for python 3.14
add 67d6402cfb3 Merge pull request #39715 from apache/fix-python314
add f353f12b543 [Dataflow Streaming] Mark worker as unhealthy in presence
of stuck commits (#39666)
add 680229c7fa7 normalize io.gcp.DicomSearch
add 569933cc905 Merge pull request #39655 from
aIbrahiim/yaml-normalize-dicom-search
add 53b03f6329a [Python] Deflake TextIO footer test (#39668)
add 33b40fbf5c4 Bump github.com/aws/aws-sdk-go-v2/config in /sdks (#39692)
add 7dda2cdb72d Enable Apache Iceberg REST Metrics Reporting for Lakehouse
(#39650)
add ce45298a609 Fixes to delta CDC read (#39713)
add e344ec03fb7 Python timestamp fixes. (#39722)
add 524036fb523 bump FnAPI container to beam-master-20260811 (#39721)
No new revisions were added by this update.
Summary of changes:
.../beam_PostCommit_Yaml_Xlang_Direct.json | 2 +-
.../workflows/beam_PostRelease_NightlySnapshot.yml | 9 +-
.github/workflows/build_release_candidate.yml | 12 +-
.github/workflows/codeql.yml | 2 +-
CHANGES.md | 1 +
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 1 +
it/mongodb/build.gradle | 1 +
.../beam/it/mongodb/MongoDBResourceManager.java | 11 +-
.../it/mongodb/MongoDBResourceManagerTest.java | 5 +
release/build.gradle.kts | 2 +-
release/src/main/groovy/TestScripts.groovy | 156 +++++++++++++++---
.../main/groovy/mobilegaming-java-dataflow.groovy | 75 ++++++---
.../main/groovy/mobilegaming-java-direct.groovy | 73 +++++++--
.../main/groovy/quickstart-java-flinklocal.groovy | 4 +-
.../src/main/groovy/quickstart-java-spark.groovy | 20 ++-
.../options/DataflowStreamingPipelineOptions.java | 2 +-
.../google-cloud-dataflow-java/worker/build.gradle | 1 +
.../dataflow/worker/StreamingDataflowWorker.java | 34 +++-
.../logging/DataflowWorkerLoggingHandler.java | 30 +++-
.../logging/DataflowWorkerLoggingInitializer.java | 4 +
.../dataflow/worker/streaming/ActiveWorkState.java | 46 ++----
.../worker/streaming/ComputationState.java | 5 +-
.../windmill/work/refresh/ActiveWorkRefresher.java | 21 +--
.../worker/StreamingDataflowWorkerTest.java | 38 ++---
.../logging/DataflowWorkerLoggingHandlerTest.java | 103 ++++++++++--
.../worker/streaming/ActiveWorkStateTest.java | 42 ++---
.../work/refresh/ActiveWorkRefresherTest.java | 69 --------
sdks/go.mod | 24 +--
sdks/go.sum | 48 +++---
.../apache/beam/sdk/options/SdkHarnessOptions.java | 7 +
.../beam/sdk/io/delta/DeltaCDCSourceDoFn.java | 24 +--
.../java/org/apache/beam/sdk/io/delta/DeltaIO.java | 4 +-
.../org/apache/beam/sdk/io/delta/DeltaIOTest.java | 98 ++++++++++++
.../org/apache/beam/sdk/io/iceberg/IcebergIO.java | 10 ++
.../org/apache/beam/sdk/io/iceberg/AddFilesIT.java | 3 +-
.../IcebergWriteSchemaTransformProviderTest.java | 63 ++++++++
.../sdk/io/iceberg/catalog/RESTCatalogBLMSIT.java | 1 -
.../beam/sdk/io/mongodb/MongoDbGridFSIO.java | 8 +-
.../org/apache/beam/sdk/io/mongodb/MongoDbIO.java | 14 +-
.../org/apache/beam/io/requestresponse/Call.java | 11 +-
.../apache/beam/io/requestresponse/CallTest.java | 51 +++++-
sdks/python/apache_beam/io/gcp/bigquery_tools.py | 8 +
.../apache_beam/io/gcp/healthcare/dicomclient.py | 5 +-
sdks/python/apache_beam/io/gcp/pubsub_test.py | 42 +++++
sdks/python/apache_beam/io/textio_test.py | 7 +-
.../apache_beam/runners/dataflow/internal/names.py | 2 +-
.../runners/direct/transform_evaluator.py | 5 +
sdks/python/apache_beam/transforms/combiners.py | 58 +++++++
.../apache_beam/transforms/combiners_test.py | 54 +++++++
.../transforms/managed_iceberg_it_test.py | 3 +-
sdks/python/apache_beam/typehints/schemas.py | 10 +-
sdks/python/apache_beam/typehints/schemas_test.py | 10 ++
sdks/python/apache_beam/utils/timestamp.py | 5 +-
sdks/python/apache_beam/utils/timestamp_test.py | 17 ++
sdks/python/apache_beam/yaml/standard_io.yaml | 1 +
sdks/python/apache_beam/yaml/yaml_io.py | 129 +++++++++++++++
sdks/python/apache_beam/yaml/yaml_io_test.py | 176 +++++++++++++++++++++
sdks/python/container/Dockerfile | 4 +-
.../license_scripts/upgrade_bundled_pip.py | 15 +-
sdks/python/pyproject.toml | 3 +-
60 files changed, 1330 insertions(+), 359 deletions(-)
