[hotfix] Fix NPE in RescaleAction

JingsongLi · JingsongLi · commit a208ffa56c48 · 2025-03-10T18:37:31.000+08:00
diff --git a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSinkBuilder.java b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/FlinkSinkBuilder.java
@@ -134,7 +134,7 @@ public FlinkSinkBuilder overwrite(Map<String, String> overwritePartition) {
     }
 
     /** Set sink parallelism. */
-    public FlinkSinkBuilder parallelism(int parallelism) {
+    public FlinkSinkBuilder parallelism(@Nullable Integer parallelism) {
         this.parallelism = parallelism;
         return this;
     }

Original file line number	Diff line number	Diff line change
`@@ -134,7 +134,7 @@ public FlinkSinkBuilder overwrite(Map<String, String> overwritePartition) {`
`134`	`134`	`}`
`135`	`135`
`136`	`136`	`/** Set sink parallelism. */`
`137`		`- public FlinkSinkBuilder parallelism(int parallelism) {`
	`137`	`+ public FlinkSinkBuilder parallelism(@Nullable Integer parallelism) {`
`138`	`138`	`this.parallelism = parallelism;`
`139`	`139`	`return this;`
`140`	`140`	`}`