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