From 29a15fd732f667cdbfb71ab218a2c581c759ce65 Mon Sep 17 00:00:00 2001 From: Evan Wu Date: Fri, 17 Apr 2026 23:53:18 -0700 Subject: [PATCH] Flink 2.1: Fix forward-writer chaining regression in DynamicIcebergSink --- .../apache/iceberg/flink/sink/dynamic/DynamicIcebergSink.java | 1 + 1 file changed, 1 insertion(+) diff --git a/flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicIcebergSink.java b/flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicIcebergSink.java index 9c8a4d156ff9..7b0de6fbe9e3 100644 --- a/flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicIcebergSink.java +++ b/flink/v2.1/flink/src/main/java/org/apache/iceberg/flink/sink/dynamic/DynamicIcebergSink.java @@ -443,6 +443,7 @@ private DynamicIcebergSink build( operatorName("Forward-Writer"), writeResultTypeInfo, new SinkWriterOperatorFactory<>(forwardWriterSink)) + .setParallelism(converted.getParallelism()) .uid(prefixIfNotNull(uidPrefix, "-forward-writer")); // Inject forward write results into sink — they'll be unioned in addPreCommitTopology