Skip to content

Commit 61d1964

Browse files
authored
[Fix][Connector-V2] Fix paimon e2e error (#7721)
1 parent 134ff33 commit 61d1964

File tree

1 file changed

+8
-6
lines changed
  • seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/sink

1 file changed

+8
-6
lines changed

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

Lines changed: 8 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -83,7 +83,7 @@ public class PaimonSinkWriter
8383

8484
private final TableSchema tableSchema;
8585

86-
private final PaimonBucketAssigner bucketAssigner;
86+
private PaimonBucketAssigner bucketAssigner;
8787

8888
private final boolean dynamicBucket;
8989

@@ -103,14 +103,16 @@ public PaimonSinkWriter(
103103
this.context = context;
104104
this.jobContext = jobContext;
105105
this.tableSchema = ((FileStoreTable) table).schema();
106-
this.bucketAssigner =
107-
new PaimonBucketAssigner(
108-
table,
109-
this.context.getNumberOfParallelSubtasks(),
110-
this.context.getIndexOfSubtask());
111106
BucketMode bucketMode = ((FileStoreTable) table).bucketMode();
112107
this.dynamicBucket =
113108
BucketMode.DYNAMIC == bucketMode || BucketMode.GLOBAL_DYNAMIC == bucketMode;
109+
if (dynamicBucket) {
110+
this.bucketAssigner =
111+
new PaimonBucketAssigner(
112+
table,
113+
this.context.getNumberOfParallelSubtasks(),
114+
this.context.getIndexOfSubtask());
115+
}
114116
PaimonSecurityContext.shouldEnableKerberos(paimonHadoopConfiguration);
115117
}
116118

0 commit comments

Comments
 (0)