[Fix][Connector-V2] Fix paimon e2e error (apache#7721)

PeppaPage · Sep 23, 2024 · 61d1964 · 61d1964
1 parent 134ff33
commit 61d1964
Showing 1 changed file with 8 additions and 6 deletions.
diff --git a/...src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/sink/PaimonSinkWriter.java b/...src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/sink/PaimonSinkWriter.java
@@ -83,7 +83,7 @@ public class PaimonSinkWriter
 
     private final TableSchema tableSchema;
 
-    private final PaimonBucketAssigner bucketAssigner;
+    private PaimonBucketAssigner bucketAssigner;
 
     private final boolean dynamicBucket;
 
@@ -103,14 +103,16 @@ public PaimonSinkWriter(
         this.context = context;
         this.jobContext = jobContext;
         this.tableSchema = ((FileStoreTable) table).schema();
-        this.bucketAssigner =
-                new PaimonBucketAssigner(
-                        table,
-                        this.context.getNumberOfParallelSubtasks(),
-                        this.context.getIndexOfSubtask());
         BucketMode bucketMode = ((FileStoreTable) table).bucketMode();
         this.dynamicBucket =
                 BucketMode.DYNAMIC == bucketMode || BucketMode.GLOBAL_DYNAMIC == bucketMode;
+        if (dynamicBucket) {
+            this.bucketAssigner =
+                    new PaimonBucketAssigner(
+                            table,
+                            this.context.getNumberOfParallelSubtasks(),
+                            this.context.getIndexOfSubtask());
+        }
         PaimonSecurityContext.shouldEnableKerberos(paimonHadoopConfiguration);
     }