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 74cf00b981 [core] Fix sequence.field parsing to trim spaces like 
primary-key (#6651)
74cf00b981 is described below

commit 74cf00b981917f327fc5bb9d3682ce7bf1d9b62b
Author: yueqingshu <[email protected]>
AuthorDate: Mon Nov 24 18:44:57 2025 +0800

    [core] Fix sequence.field parsing to trim spaces like primary-key (#6651)
---
 paimon-api/src/main/java/org/apache/paimon/CoreOptions.java      | 6 +++++-
 paimon-core/src/test/java/org/apache/paimon/CoreOptionsTest.java | 9 +++++++++
 2 files changed, 14 insertions(+), 1 deletion(-)

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 be17211965..9cf4056001 100644
--- a/paimon-api/src/main/java/org/apache/paimon/CoreOptions.java
+++ b/paimon-api/src/main/java/org/apache/paimon/CoreOptions.java
@@ -2817,7 +2817,11 @@ public class CoreOptions implements Serializable {
 
     public List<String> sequenceField() {
         return options.getOptional(SEQUENCE_FIELD)
-                .map(s -> Arrays.asList(s.split(",")))
+                .map(
+                        s ->
+                                Arrays.stream(s.split(","))
+                                        .map(String::trim)
+                                        .collect(Collectors.toList()))
                 .orElse(Collections.emptyList());
     }
 
diff --git a/paimon-core/src/test/java/org/apache/paimon/CoreOptionsTest.java 
b/paimon-core/src/test/java/org/apache/paimon/CoreOptionsTest.java
index bf5445fc10..46551a5134 100644
--- a/paimon-core/src/test/java/org/apache/paimon/CoreOptionsTest.java
+++ b/paimon-core/src/test/java/org/apache/paimon/CoreOptionsTest.java
@@ -86,4 +86,13 @@ public class CoreOptionsTest {
         conf.set(CoreOptions.LOOKUP_WAIT, false);
         assertThat(options.prepareCommitWaitCompaction()).isFalse();
     }
+
+    @Test
+    public void testSequenceFieldTrim() {
+        Options conf = new Options();
+        conf.set(CoreOptions.SEQUENCE_FIELD, " f1 ,f2 ,  f3  ");
+
+        CoreOptions options = new CoreOptions(conf);
+        assertThat(options.sequenceField()).containsExactly("f1", "f2", "f3");
+    }
 }

Reply via email to