diff --git a/parquet-protobuf/src/main/java/org/apache/parquet/proto/ProtoSchemaConverter.java b/parquet-protobuf/src/main/java/org/apache/parquet/proto/ProtoSchemaConverter.java index 57ac15a9e6..a5b4edebe5 100644 --- a/parquet-protobuf/src/main/java/org/apache/parquet/proto/ProtoSchemaConverter.java +++ b/parquet-protobuf/src/main/java/org/apache/parquet/proto/ProtoSchemaConverter.java @@ -99,7 +99,7 @@ private Builder>, GroupBuilder> addR return builder .group(Type.Repetition.REQUIRED).as(OriginalType.LIST) .group(Type.Repetition.REPEATED) - .primitive(primitiveType, Type.Repetition.OPTIONAL).as(originalType) + .primitive(primitiveType, Type.Repetition.REQUIRED).as(originalType) .named("element") .named("list"); } diff --git a/parquet-protobuf/src/test/java/org/apache/parquet/proto/ProtoSchemaConverterTest.java b/parquet-protobuf/src/test/java/org/apache/parquet/proto/ProtoSchemaConverterTest.java index 9f3dcc8420..34f2f23f2f 100644 --- a/parquet-protobuf/src/test/java/org/apache/parquet/proto/ProtoSchemaConverterTest.java +++ b/parquet-protobuf/src/test/java/org/apache/parquet/proto/ProtoSchemaConverterTest.java @@ -124,7 +124,7 @@ public void testConvertRepetition() throws Exception { " required int32 requiredPrimitive = 2;\n" + " required group repeatedPrimitive (LIST) = 3 {\n" + " repeated group list {\n" + - " optional int32 element;\n" + + " required int32 element;\n" + " }\n" + " }\n" + " optional group optionalMessage = 7 {\n" + @@ -150,7 +150,7 @@ public void testProto3ConvertRepetition() throws Exception { " optional int32 optionalPrimitive = 1;\n" + " required group repeatedPrimitive (LIST) = 3 {\n" + " repeated group list {\n" + - " optional int32 element;\n" + + " required int32 element;\n" + " }\n" + " }\n" + " optional group optionalMessage = 7 {\n" +