(paimon) branch master updated: [core] Improve clustering columns parsing with trim support (#7159)

[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 d2bbafabe9 [core] Improve clustering columns parsing with trim support 
(#7159)
d2bbafabe9 is described below

commit d2bbafabe9dbf480bf69f6865a6e5a5461da79ed
Author: LsomeYeah <94825748+lsomey...@users.noreply.github.com>
AuthorDate: Fri Jan 30 19:00:30 2026 +0800

    [core] Improve clustering columns parsing with trim support (#7159)
---
 paimon-api/src/main/java/org/apache/paimon/CoreOptions.java           | 4 +++-
 .../paimon/append/cluster/BucketedAppendClusterManagerTest.java       | 2 +-
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/paimon-api/src/main/java/org/apache/paimon/CoreOptions.java 
b/paimon-api/src/main/java/org/apache/paimon/CoreOptions.java
index 95f1387491..c0e2084524 100644
--- a/paimon-api/src/main/java/org/apache/paimon/CoreOptions.java
+++ b/paimon-api/src/main/java/org/apache/paimon/CoreOptions.java
@@ -3338,7 +3338,9 @@ public class CoreOptions implements Serializable {
         if (clusteringColumns == null || clusteringColumns.isEmpty()) {
             return Collections.emptyList();
         }
-        return Arrays.asList(clusteringColumns.split(","));
+        return Arrays.stream(clusteringColumns.split(","))
+                .map(String::trim)
+                .collect(Collectors.toList());
     }
 
     public static OrderType clusteringStrategy(String clusteringStrategy, int 
columnSize) {
diff --git 
a/paimon-core/src/test/java/org/apache/paimon/append/cluster/BucketedAppendClusterManagerTest.java
 
b/paimon-core/src/test/java/org/apache/paimon/append/cluster/BucketedAppendClusterManagerTest.java
index d7a3d5d59e..5efdee2d70 100644
--- 
a/paimon-core/src/test/java/org/apache/paimon/append/cluster/BucketedAppendClusterManagerTest.java
+++ 
b/paimon-core/src/test/java/org/apache/paimon/append/cluster/BucketedAppendClusterManagerTest.java
@@ -144,7 +144,7 @@ public class BucketedAppendClusterManagerTest {
                         .option("bucket", "1")
                         .option("bucket-key", "f0")
                         .option("compaction.min.file-num", "10")
-                        .option("clustering.columns", "f1,f2")
+                        .option("clustering.columns", "f1, f2")
                         .option("clustering.strategy", "zorder")
                         .build();
         Identifier identifier = Identifier.create("default", "test");