typo

MaxNevermind · Aug 7, 2024 · c521a95 · c521a95
1 parent 21a5926
commit c521a95
Showing 1 changed file with 3 additions and 3 deletions.
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
@@ -336,13 +336,13 @@ public void processBlocks() throws IOException {
           ColumnPath colPath =
               ColumnPath.get(outColumns.get(outColumnIdx).getPath());
           if (readerJoin != null) {
-            Optional<ColumnChunkMetaData> chunkJoin =
+            Optional<ColumnChunkMetaData> chunkToJoin =
                 readerJoin.getFooter().getBlocks().get(blockIdxJoin).getColumns().stream()
                     .filter(x -> x.getPath().equals(colPath))
                     .findFirst();
-            if (chunkJoin.isPresent()
+            if (chunkToJoin.isPresent()
                 && (overwriteInputWithJoinColumns || !columnPaths.contains(colPath))) {
-              processBlock(readerJoin, blockIdxJoin, outColumnIdx, indexCacheJoin, chunkJoin.get());
+              processBlock(readerJoin, blockIdxJoin, outColumnIdx, indexCacheJoin, chunkToJoin.get());
             } else {
               processBlock(reader, blockIdx, outColumnIdx, indexCache, pathToChunk.get(colPath));
             }