Spark: Fix list behavior in StructInternalRow (apache#1943)

dujl · Dec 17, 2020 · 81c3141 · 81c3141
1 parent dbfb036
commit 81c3141
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/spark/src/main/java/org/apache/iceberg/spark/source/StructInternalRow.java b/spark/src/main/java/org/apache/iceberg/spark/source/StructInternalRow.java
@@ -278,7 +278,7 @@ private ArrayData collectionToArrayData(Type elementType, Collection<?> values)
             array[pos] = new StructInternalRow(elementType.asStructType(), tuple));
       case LIST:
         return fillArray(values, array -> (BiConsumer<Integer, Collection<?>>) (pos, list) ->
-            array[pos] = collectionToArrayData(elementType.asListType(), list));
+            array[pos] = collectionToArrayData(elementType.asListType().elementType(), list));
       case MAP:
         return fillArray(values, array -> (BiConsumer<Integer, Map<?, ?>>) (pos, map) ->
             array[pos] = mapToMapData(elementType.asMapType(), map));