Skip to content

Commit 0069895

Browse files
committed
Update
1 parent d931141 commit 0069895

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

sql/core/src/main/scala/org/apache/spark/sql/parquet/CatalystSchemaConverter.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -490,7 +490,7 @@ private[parquet] class CatalystSchemaConverter(
490490
.buildGroup(repetition).as(LIST)
491491
.addField(
492492
Types.repeatedGroup()
493-
.addField(convertField(StructField("array", elementType, containsNull)))
493+
.addField(convertField(StructField("element", elementType, containsNull)))
494494
.named("list"))
495495
.named(field.name)
496496

sql/core/src/test/scala/org/apache/spark/sql/parquet/ParquetSchemaSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -603,7 +603,7 @@ class ParquetSchemaSuite extends ParquetSchemaTest {
603603
"""message root {
604604
| optional group f1 (LIST) {
605605
| repeated group list {
606-
| optional int32 array;
606+
| optional int32 element;
607607
| }
608608
| }
609609
|}
@@ -636,7 +636,7 @@ class ParquetSchemaSuite extends ParquetSchemaTest {
636636
"""message root {
637637
| optional group f1 (LIST) {
638638
| repeated group list {
639-
| required int32 array;
639+
| required int32 element;
640640
| }
641641
| }
642642
|}

0 commit comments

Comments
 (0)