(fluss) branch main updated: [flink] Remove redundant `bucket.num` and `bucket.key` from custom properties. (#2931)

[hongshun]

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

hongshun pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git


The following commit(s) were added to refs/heads/main by this push:
     new 97cc67d06 [flink] Remove redundant `bucket.num` and `bucket.key` from 
custom properties. (#2931)
97cc67d06 is described below

commit 97cc67d06ac523216773515ee88cb2dd0da409cf
Author: Hongshun Wang <125648852+loserwang1...@users.noreply.github.com>
AuthorDate: Thu Mar 26 18:01:58 2026 +0800

    [flink] Remove redundant `bucket.num` and `bucket.key` from custom 
properties. (#2931)
---
 .../src/main/java/org/apache/fluss/flink/utils/FlinkConversions.java  | 4 ++++
 .../test/java/org/apache/fluss/flink/catalog/FlinkCatalogITCase.java  | 2 +-
 2 files changed, 5 insertions(+), 1 deletion(-)

diff --git 
a/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/utils/FlinkConversions.java
 
b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/utils/FlinkConversions.java
index 2c908e128..01f9a9817 100644
--- 
a/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/utils/FlinkConversions.java
+++ 
b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/utils/FlinkConversions.java
@@ -709,6 +709,10 @@ public class FlinkConversions {
             Configuration allProperties, Map<String, String> 
flussTableProperties) {
         Map<String, String> customProperties = new 
HashMap<>(allProperties.toMap());
         customProperties.keySet().removeAll(flussTableProperties.keySet());
+        // Remove bucket key and bucket num which is stored as table 
distribution rather than custom
+        // properties.
+        customProperties.remove(BUCKET_KEY.key());
+        customProperties.remove(BUCKET_NUMBER.key());
         return customProperties;
     }
 }
diff --git 
a/fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/catalog/FlinkCatalogITCase.java
 
b/fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/catalog/FlinkCatalogITCase.java
index 638229d8f..d9516821e 100644
--- 
a/fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/catalog/FlinkCatalogITCase.java
+++ 
b/fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/catalog/FlinkCatalogITCase.java
@@ -637,8 +637,8 @@ abstract class FlinkCatalogITCase {
             expectedCustomProperties.put("schema.4.name", "cost");
             expectedCustomProperties.put("schema.4.expr", "`price` * 
`quantity`");
             expectedCustomProperties.put("schema.4.data-type", "DOUBLE");
-            expectedCustomProperties.put("bucket.num", "2");
             
assertThat(tableInfo.getCustomProperties().toMap()).isEqualTo(expectedCustomProperties);
+            assertThat(tableInfo.getNumBuckets()).isEqualTo(2);
         }
     }