This is an automated email from the ASF dual-hosted git repository. Amar3tto pushed a commit to branch fix-managed-iceberg in repository https://gitbox.apache.org/repos/asf/beam.git
commit 1e43b219b71c5528167798e1a35e3df926f0dd17 Author: Vitaly Terentyev <[email protected]> AuthorDate: Thu Oct 22 12:33:54 2026 +0400 Test legacy worker --- .../apache/beam/sdk/io/iceberg/catalog/IcebergCdcWriteBaseIT.java | 6 +++--- .../beam/sdk/io/iceberg/cdc/sink/DeltaLakeToIcebergCdcIT.java | 6 +++--- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/sdks/java/io/iceberg/src/test/java/org/apache/beam/sdk/io/iceberg/catalog/IcebergCdcWriteBaseIT.java b/sdks/java/io/iceberg/src/test/java/org/apache/beam/sdk/io/iceberg/catalog/IcebergCdcWriteBaseIT.java index d641a0e5f39..97add476eb0 100644 --- a/sdks/java/io/iceberg/src/test/java/org/apache/beam/sdk/io/iceberg/catalog/IcebergCdcWriteBaseIT.java +++ b/sdks/java/io/iceberg/src/test/java/org/apache/beam/sdk/io/iceberg/catalog/IcebergCdcWriteBaseIT.java @@ -855,9 +855,9 @@ public abstract class IcebergCdcWriteBaseIT implements Serializable { } metadataColumns.add(IcebergCdcMetadataColumns.COMMIT_SNAPSHOT_SEQUENCE_NUMBER); PipelineOptions options = TestPipeline.testingPipelineOptions(); - if (!changeTypeColumn) { - CdcSinkTestUtils.useLegacyDataflowWorker(options); - } +// if (!changeTypeColumn) { + CdcSinkTestUtils.useLegacyDataflowWorker(options); +// } Map<String, Object> readConfig = new HashMap<>(managedIcebergConfig(sourceId.toString())); readConfig.put("include_metadata_columns", metadataColumns); Map<String, Object> writeConfig = new HashMap<>(managedIcebergConfig(targetId.toString())); diff --git a/sdks/java/io/iceberg/src/test/java/org/apache/beam/sdk/io/iceberg/cdc/sink/DeltaLakeToIcebergCdcIT.java b/sdks/java/io/iceberg/src/test/java/org/apache/beam/sdk/io/iceberg/cdc/sink/DeltaLakeToIcebergCdcIT.java index b48b910b682..bb4dcfea7e6 100644 --- a/sdks/java/io/iceberg/src/test/java/org/apache/beam/sdk/io/iceberg/cdc/sink/DeltaLakeToIcebergCdcIT.java +++ b/sdks/java/io/iceberg/src/test/java/org/apache/beam/sdk/io/iceberg/cdc/sink/DeltaLakeToIcebergCdcIT.java @@ -311,9 +311,9 @@ public class DeltaLakeToIcebergCdcIT { // The native ValueKind does not survive Dataflow Runner v2 yet, so that variant runs on the // legacy worker there; the change-type column travels on any runner. - if (!changeTypeColumn) { - CdcSinkTestUtils.useLegacyDataflowWorker(p.getOptions()); - } +// if (!changeTypeColumn) { + CdcSinkTestUtils.useLegacyDataflowWorker(p.getOptions()); +// } Map<String, Object> readConfig = new HashMap<>(); readConfig.put("table", deltaTable); readConfig.put("start_version", 0L);
