(seatunnel) branch dev updated: [Fix][Connector-V2] Fix paimon e2e error (#7721)

[tyrantlucifer]

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

tyrantlucifer pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 61d1964361 [Fix][Connector-V2] Fix paimon e2e error (#7721)
61d1964361 is described below

commit 61d19643612a4ea5dccd583f77fdd07c5e1de84c
Author: zhangdonghao <39961809+hawk9...@users.noreply.github.com>
AuthorDate: Mon Sep 23 21:08:40 2024 +0800

    [Fix][Connector-V2] Fix paimon e2e error (#7721)
---
 .../connectors/seatunnel/paimon/sink/PaimonSinkWriter.java | 14 ++++++++------
 1 file changed, 8 insertions(+), 6 deletions(-)

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 d58ab65cf7..97e66f14f5 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 @@ public class PaimonSinkWriter
 
     private final TableSchema tableSchema;
 
-    private final PaimonBucketAssigner bucketAssigner;
+    private PaimonBucketAssigner bucketAssigner;
 
     private final boolean dynamicBucket;
 
@@ -103,14 +103,16 @@ public class 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);
     }