Skip to content

Commit 680b8d9

Browse files
Fix AvroParquetReader
1 parent 0cc76f1 commit 680b8d9

2 files changed

Lines changed: 2 additions & 1 deletion

File tree

parquet-avro/src/main/java/org/apache/parquet/avro/AvroParquetReader.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -132,7 +132,7 @@ public static class Builder<T> extends ParquetReader.Builder<T> {
132132

133133
private GenericData model = null;
134134
private boolean enableCompatibility = true;
135-
private boolean isReflect = true;
135+
private boolean isReflect = false;
136136

137137
@Deprecated
138138
private Builder(Path path) {

parquet-avro/src/test/java/org/apache/parquet/avro/TestReadWrite.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -829,6 +829,7 @@ public void testNestedListsDisk() throws Exception {
829829

830830
try (ParquetReader<GenericRecord> reader = AvroParquetReader
831831
.<GenericRecord>builder(new DiskInputFile(file))
832+
.withCompatibility(testConf.getBoolean(AvroReadSupport.AVRO_COMPATIBILITY, true))
832833
.withDataModel(GenericData.get())
833834
.withConf(testConf)
834835
.build()) {

0 commit comments

Comments
 (0)