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");
+ }
}