Skip to content

Commit 4fa92ba

Browse files
Fix AvroParquetReader
1 parent 0cc76f1 commit 4fa92ba

2 files changed

Lines changed: 2 additions & 2 deletions

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 & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -829,7 +829,7 @@ public void testNestedListsDisk() throws Exception {
829829

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

0 commit comments

Comments
 (0)