(paimon) branch master updated: [core] Remove useless bucketMode in TableWriteImpl

[lzljs3620320]

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

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 77ed1d75b5 [core] Remove useless bucketMode in TableWriteImpl
77ed1d75b5 is described below

commit 77ed1d75b56c991b4368a3ff2765708e247ebe18
Author: JingsongLi <jingsongl...@gmail.com>
AuthorDate: Fri Jan 9 15:12:07 2026 +0800

    [core] Remove useless bucketMode in TableWriteImpl
---
 .../src/main/java/org/apache/paimon/table/sink/TableWriteImpl.java | 7 -------
 .../main/java/org/apache/paimon/flink/sink/StoreSinkWriteImpl.java | 1 -
 2 files changed, 8 deletions(-)

diff --git 
a/paimon-core/src/main/java/org/apache/paimon/table/sink/TableWriteImpl.java 
b/paimon-core/src/main/java/org/apache/paimon/table/sink/TableWriteImpl.java
index 5f91c07bb0..b5e9cebbb5 100644
--- a/paimon-core/src/main/java/org/apache/paimon/table/sink/TableWriteImpl.java
+++ b/paimon-core/src/main/java/org/apache/paimon/table/sink/TableWriteImpl.java
@@ -31,7 +31,6 @@ import org.apache.paimon.operation.BundleFileStoreWriter;
 import org.apache.paimon.operation.FileStoreWrite;
 import org.apache.paimon.operation.FileStoreWrite.State;
 import org.apache.paimon.operation.WriteRestore;
-import org.apache.paimon.table.BucketMode;
 import org.apache.paimon.types.DataField;
 import org.apache.paimon.types.RowKind;
 import org.apache.paimon.types.RowType;
@@ -60,7 +59,6 @@ public class TableWriteImpl<T> implements InnerTableWrite, 
Restorable<List<State
     @Nullable private final RowKindFilter rowKindFilter;
 
     private boolean batchCommitted = false;
-    private BucketMode bucketMode;
     private RowType writeType;
     private int[] notNullFieldIndex;
 
@@ -135,11 +133,6 @@ public class TableWriteImpl<T> implements InnerTableWrite, 
Restorable<List<State
         return this;
     }
 
-    public TableWriteImpl<T> withBucketMode(BucketMode bucketMode) {
-        this.bucketMode = bucketMode;
-        return this;
-    }
-
     @Override
     public BinaryRow getPartition(InternalRow row) {
         keyAndBucketExtractor.setRecord(row);
diff --git 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreSinkWriteImpl.java
 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreSinkWriteImpl.java
index 289f465a17..41c23f5002 100644
--- 
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreSinkWriteImpl.java
+++ 
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/StoreSinkWriteImpl.java
@@ -85,7 +85,6 @@ public class StoreSinkWriteImpl implements StoreSinkWrite {
                 table.newWrite(commitUser, state.getSubtaskId())
                         .withIOManager(paimonIOManager)
                         .withIgnorePreviousFiles(ignorePreviousFiles)
-                        .withBucketMode(table.bucketMode())
                         .withMemoryPoolFactory(memoryPoolFactory);
 
         if (metricGroup != null) {