Skip to content

Commit 46595e2

Browse files
authored
Avro: Fix test configuration (#3244)
1 parent 0301347 commit 46595e2

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -962,9 +962,9 @@ private ParquetWriter<GenericRecord> writer(String file, Schema schema) throws I
962962
writerBuilder.withCodecFactory(HadoopCodecs.newFactory(ParquetProperties.DEFAULT_PAGE_SIZE));
963963
}
964964
if (conf == ConfigurationType.PLAIN_PARQUET_INTERFACE) {
965-
return writerBuilder.withConf(hadoopConfWithInterface).build();
966-
} else if (conf == ConfigurationType.HADOOP_PARQUET_INTERFACE) {
967965
return writerBuilder.withConf(plainParquetConf).build();
966+
} else if (conf == ConfigurationType.HADOOP_PARQUET_INTERFACE) {
967+
return writerBuilder.withConf(hadoopConfWithInterface).build();
968968
} else {
969969
return writerBuilder.withConf(testConf).build();
970970
}
@@ -983,9 +983,9 @@ private ParquetReader<GenericRecord> reader(String file) throws IOException {
983983
readerBuilder.withCodecFactory(HadoopCodecs.newFactory(ParquetProperties.DEFAULT_PAGE_SIZE));
984984
}
985985
if (conf == ConfigurationType.PLAIN_PARQUET_INTERFACE) {
986-
return readerBuilder.withConf(hadoopConfWithInterface).build();
987-
} else if (conf == ConfigurationType.HADOOP_PARQUET_INTERFACE) {
988986
return readerBuilder.withConf(plainParquetConf).build();
987+
} else if (conf == ConfigurationType.HADOOP_PARQUET_INTERFACE) {
988+
return readerBuilder.withConf(hadoopConfWithInterface).build();
989989
} else {
990990
return readerBuilder.withConf(testConf).build();
991991
}

0 commit comments

Comments
 (0)