This is an automated email from the ASF dual-hosted git repository.
JingsongLi 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 ce9987c999 [lance] Reject unsupported MULTISET type in LanceFileFormat
schema validation (#8678)
ce9987c999 is described below
commit ce9987c9997c81f9e22b538a87f2e587059f2136
Author: Eunbin Son <[email protected]>
AuthorDate: Thu Jul 16 14:16:43 2026 +0900
[lance] Reject unsupported MULTISET type in LanceFileFormat schema
validation (#8678)
---
.../main/java/org/apache/paimon/format/lance/LanceFileFormat.java | 3 ++-
.../java/org/apache/paimon/format/lance/LanceFileFormatTest.java | 8 ++++++++
2 files changed, 10 insertions(+), 1 deletion(-)
diff --git
a/paimon-lance/src/main/java/org/apache/paimon/format/lance/LanceFileFormat.java
b/paimon-lance/src/main/java/org/apache/paimon/format/lance/LanceFileFormat.java
index 64b4e2887f..52184ad798 100644
---
a/paimon-lance/src/main/java/org/apache/paimon/format/lance/LanceFileFormat.java
+++
b/paimon-lance/src/main/java/org/apache/paimon/format/lance/LanceFileFormat.java
@@ -200,7 +200,8 @@ public class LanceFileFormat extends FileFormat {
@Override
public Void visit(MultisetType multisetType) {
- return null;
+ throw new UnsupportedOperationException(
+ "Lance file format does not support type MULTISET");
}
@Override
diff --git
a/paimon-lance/src/test/java/org/apache/paimon/format/lance/LanceFileFormatTest.java
b/paimon-lance/src/test/java/org/apache/paimon/format/lance/LanceFileFormatTest.java
index c731ce2590..ab63fc91ac 100644
---
a/paimon-lance/src/test/java/org/apache/paimon/format/lance/LanceFileFormatTest.java
+++
b/paimon-lance/src/test/java/org/apache/paimon/format/lance/LanceFileFormatTest.java
@@ -55,6 +55,14 @@ public class LanceFileFormatTest {
assertThrows(UnsupportedOperationException.class, () ->
format.validateDataFields(rowType));
}
+ @Test
+ public void testValidateDataFields_UnsupportedMultisetType() {
+ LanceFileFormat format =
+ new LanceFileFormat(new FileFormatFactory.FormatContext(new
Options(), 1024, 1024));
+ RowType rowType = RowType.of(DataTypes.MULTISET(DataTypes.STRING()));
+ assertThrows(UnsupportedOperationException.class, () ->
format.validateDataFields(rowType));
+ }
+
@Test
public void testValidateDataFields_SupportedTypes() {
LanceFileFormat format =