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 ff1185012b [vortex] Reject unsupported element types nested in ARRAY
(#8690)
ff1185012b is described below
commit ff1185012bf83cb91c4e3fbb357e4a716ee8625d
Author: Eunbin Son <[email protected]>
AuthorDate: Thu Jul 16 14:12:45 2026 +0900
[vortex] Reject unsupported element types nested in ARRAY (#8690)
---
.../apache/paimon/format/vortex/VortexFileFormat.java | 2 +-
.../paimon/format/vortex/VortexFileFormatTest.java | 19 +++++++++++++++++++
2 files changed, 20 insertions(+), 1 deletion(-)
diff --git
a/paimon-vortex/paimon-vortex-format/src/main/java/org/apache/paimon/format/vortex/VortexFileFormat.java
b/paimon-vortex/paimon-vortex-format/src/main/java/org/apache/paimon/format/vortex/VortexFileFormat.java
index 46e13d6cb4..7f13b14a6d 100644
---
a/paimon-vortex/paimon-vortex-format/src/main/java/org/apache/paimon/format/vortex/VortexFileFormat.java
+++
b/paimon-vortex/paimon-vortex-format/src/main/java/org/apache/paimon/format/vortex/VortexFileFormat.java
@@ -183,7 +183,7 @@ public class VortexFileFormat extends FileFormat {
@Override
public Void visit(ArrayType arrayType) {
- return null;
+ return arrayType.getElementType().accept(this);
}
@Override
diff --git
a/paimon-vortex/paimon-vortex-format/src/test/java/org/apache/paimon/format/vortex/VortexFileFormatTest.java
b/paimon-vortex/paimon-vortex-format/src/test/java/org/apache/paimon/format/vortex/VortexFileFormatTest.java
index e3925ee361..30f1c90db0 100644
---
a/paimon-vortex/paimon-vortex-format/src/test/java/org/apache/paimon/format/vortex/VortexFileFormatTest.java
+++
b/paimon-vortex/paimon-vortex-format/src/test/java/org/apache/paimon/format/vortex/VortexFileFormatTest.java
@@ -100,6 +100,25 @@ public class VortexFileFormatTest {
assertThrows(UnsupportedOperationException.class, () ->
format.validateDataFields(rowType));
}
+ @Test
+ public void testValidateDataFields_UnsupportedTypeNestedInArray() {
+ VortexFileFormat format =
+ new VortexFileFormat(
+ new FileFormatFactory.FormatContext(new Options(),
1024, 1024));
+ RowType rowType =
+ RowType.of(DataTypes.ARRAY(DataTypes.MAP(DataTypes.STRING(),
DataTypes.INT())));
+ assertThrows(UnsupportedOperationException.class, () ->
format.validateDataFields(rowType));
+ }
+
+ @Test
+ public void testValidateDataFields_SupportedTypeNestedInArray() {
+ VortexFileFormat format =
+ new VortexFileFormat(
+ new FileFormatFactory.FormatContext(new Options(),
1024, 1024));
+ RowType rowType =
RowType.of(DataTypes.ARRAY(DataTypes.ARRAY(DataTypes.INT())));
+ assertDoesNotThrow(() -> format.validateDataFields(rowType));
+ }
+
@Test
public void testValidateDataFields_SupportedTypes() {
VortexFileFormat format =