This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new a208ffa56c [hotfix] Fix NPE in RescaleAction
a208ffa56c is described below

commit a208ffa56c486d8a6317b648af65f2a5302b4686
Author: JingsongLi <[email protected]>
AuthorDate: Mon Mar 10 18:37:31 2025 +0800

    [hotfix] Fix NPE in RescaleAction
---
 .../src/main/java/org/apache/paimon/flink/sink/FlinkSinkBuilder.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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
index 35a7d744c9..e06639d794 100644
--- 
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 class FlinkSinkBuilder {
     }
 
     /** Set sink parallelism. */
-    public FlinkSinkBuilder parallelism(int parallelism) {
+    public FlinkSinkBuilder parallelism(@Nullable Integer parallelism) {
         this.parallelism = parallelism;
         return this;
     }

Reply via email to