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 =

Reply via email to