commit 61d19643612a4ea5dccd583f77fdd07c5e1de84c
author zhangdonghao <39961809+hawk9821@users.noreply.github.com> Mon Sep 23 21:08:40 2024 +0800
committer GitHub <noreply@github.com> Mon Sep 23 21:08:40 2024 +0800
tree 7b83cb6d69a251ef1dbfdeacef4bf0ae7aa2291a
parent 134ff33e00f5a999b479b94f118410c190283235

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

seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/sink/PaimonSinkWriter.java

diff --git a/seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/sink/PaimonSinkWriter.java b/seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/sink/PaimonSinkWriter.java
index d58ab65..97e66f1 100644
--- a/seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/sink/PaimonSinkWriter.java
+++ b/seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/sink/PaimonSinkWriter.java
@@ -83,7 +83,7 @@
 
     private final TableSchema tableSchema;
 
-    private final PaimonBucketAssigner bucketAssigner;
+    private PaimonBucketAssigner bucketAssigner;
 
     private final boolean dynamicBucket;
 
@@ -103,14 +103,16 @@
         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);
     }