From 133a19095c72e0184b22a589ad1bad0a45123cfb Mon Sep 17 00:00:00 2001 From: Amar3tto Date: Thu, 6 Aug 2026 06:51:49 +0000 Subject: [PATCH 1/2] Set Dataflow container to release version. --- runners/google-cloud-dataflow-java/build.gradle | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/runners/google-cloud-dataflow-java/build.gradle b/runners/google-cloud-dataflow-java/build.gradle index ec075a4faf7d..a1139f3a6854 100644 --- a/runners/google-cloud-dataflow-java/build.gradle +++ b/runners/google-cloud-dataflow-java/build.gradle @@ -52,8 +52,8 @@ evaluationDependsOn(":sdks:java:container:java11") ext.dataflowLegacyEnvironmentMajorVersion = '8' ext.dataflowFnapiEnvironmentMajorVersion = '8' -ext.dataflowLegacyContainerVersion = 'beam-master-20260731' -ext.dataflowFnapiContainerVersion = 'beam-master-20260731' +ext.dataflowLegacyContainerVersion = '2.76.0' +ext.dataflowFnapiContainerVersion = '2.76.0' ext.dataflowContainerBaseRepository = 'gcr.io/cloud-dataflow/v1beta3' processResources { From 7b1eeaaa2db065f260c833888690b46d101c226d Mon Sep 17 00:00:00 2001 From: Vitaly Terentyev Date: Fri, 7 Aug 2026 19:05:25 +0400 Subject: [PATCH 2/2] Cherrypick #39675 --- .../apache_beam/yaml/extended_tests/databases/iceberg.yaml | 3 +++ 1 file changed, 3 insertions(+) diff --git a/sdks/python/apache_beam/yaml/extended_tests/databases/iceberg.yaml b/sdks/python/apache_beam/yaml/extended_tests/databases/iceberg.yaml index 98462f2d0271..ff328a127450 100644 --- a/sdks/python/apache_beam/yaml/extended_tests/databases/iceberg.yaml +++ b/sdks/python/apache_beam/yaml/extended_tests/databases/iceberg.yaml @@ -28,6 +28,9 @@ fixtures: - { id: 1, name: "label", required: true, type: "string" } - { id: 2, name: "rank", required: true, type: "long" } identifier-field-ids: [1] + # Required for ReadFromIcebergCDC (format version >= 2). + properties: + format-version: "2" pipelines: - name: write