diff --git a/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/rewrite/ParquetRewriter.java b/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/rewrite/ParquetRewriter.java index 865ec0fce6..99570d4d6c 100644 --- a/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/rewrite/ParquetRewriter.java +++ b/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/rewrite/ParquetRewriter.java @@ -171,7 +171,7 @@ public ParquetRewriter(RewriteOptions options) throws IOException { inputFiles.size() + inputFilesToJoin.size(), Stream.concat(options.getParquetInputFiles().stream(), options.getParquetInputFilesToJoin().stream()) .collect(Collectors.toList()), - options.getParquetOutputFile()); + out); if (options.getMaskColumns() != null) { this.maskColumns = new HashMap<>();