[apacheGH-3035][ParquetRewriter] nitpick refactoring

MaxNevermind · Nov 11, 2024 · 4d7ff10 · 4d7ff10
1 parent a5b48e2
commit 4d7ff10
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -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<>();