Skip to content

Commit 74cf00b

Browse files
authored
[core] Fix sequence.field parsing to trim spaces like primary-key (#6651)
1 parent e7fbdc8 commit 74cf00b

File tree

2 files changed

+14
-1
lines changed

2 files changed

+14
-1
lines changed

paimon-api/src/main/java/org/apache/paimon/CoreOptions.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2817,7 +2817,11 @@ public Integer dynamicBucketAssignerParallelism() {
28172817

28182818
public List<String> sequenceField() {
28192819
return options.getOptional(SEQUENCE_FIELD)
2820-
.map(s -> Arrays.asList(s.split(",")))
2820+
.map(
2821+
s ->
2822+
Arrays.stream(s.split(","))
2823+
.map(String::trim)
2824+
.collect(Collectors.toList()))
28212825
.orElse(Collections.emptyList());
28222826
}
28232827

paimon-core/src/test/java/org/apache/paimon/CoreOptionsTest.java

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -86,4 +86,13 @@ public void testPrepareCommitWaitCompaction() {
8686
conf.set(CoreOptions.LOOKUP_WAIT, false);
8787
assertThat(options.prepareCommitWaitCompaction()).isFalse();
8888
}
89+
90+
@Test
91+
public void testSequenceFieldTrim() {
92+
Options conf = new Options();
93+
conf.set(CoreOptions.SEQUENCE_FIELD, " f1 ,f2 , f3 ");
94+
95+
CoreOptions options = new CoreOptions(conf);
96+
assertThat(options.sequenceField()).containsExactly("f1", "f2", "f3");
97+
}
8998
}

0 commit comments

Comments
 (0)