From 235146c8ba610d65cf64498610c30fbdb216b07b Mon Sep 17 00:00:00 2001 From: zhangdonghao Date: Mon, 23 Sep 2024 15:57:24 +0800 Subject: [PATCH] [HotFix][CONNECTORS-V2-Paimon] Paimon dynamic bucket e2e error --- .../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 d58ab65cf70..97e66f14f56 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 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); }