fix

apache · Dec 21, 2024 · 0982da9 · 0982da9
1 parent 9a7deab
commit 0982da9
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 8 deletions.
diff --git a/paimon-common/src/main/java/org/apache/paimon/data/columnar/ColumnarRowIterator.java b/paimon-common/src/main/java/org/apache/paimon/data/columnar/ColumnarRowIterator.java
@@ -46,6 +46,10 @@ public class ColumnarRowIterator extends RecyclableIterator<InternalRow>
 
     private final boolean vectorizedAndCompactly;
 
+    public ColumnarRowIterator(Path filePath, ColumnarRow row, @Nullable Runnable recycler) {
+        this(filePath, row, recycler, true);
+    }
+
     public ColumnarRowIterator(
             Path filePath,
             ColumnarRow row,

diff --git a/paimon-common/src/main/java/org/apache/paimon/utils/IteratorResultIterator.java b/paimon-common/src/main/java/org/apache/paimon/utils/IteratorResultIterator.java
@@ -35,19 +35,15 @@ public final class IteratorResultIterator extends RecyclableIterator<InternalRow
     private final Path filePath;
     private long nextFilePos;
 
-    private final boolean vectorizedAndCompactly;
-
     public IteratorResultIterator(
             final IteratorWithException<InternalRow, IOException> records,
             final @Nullable Runnable recycler,
             final Path filePath,
-            long pos,
-            boolean vectorizedAndCompactly) {
+            long pos) {
         super(recycler);
         this.records = records;
         this.filePath = filePath;
         this.nextFilePos = pos;
-        this.vectorizedAndCompactly = vectorizedAndCompactly;
     }
 
     @Nullable
@@ -73,6 +69,6 @@ public Path filePath() {
 
     @Override
     public boolean vectorizedAndCompactly() {
-        return vectorizedAndCompactly;
+        return false;
     }
 }
diff --git a/paimon-format/src/main/java/org/apache/paimon/format/avro/AvroBulkFormat.java b/paimon-format/src/main/java/org/apache/paimon/format/avro/AvroBulkFormat.java
@@ -110,7 +110,7 @@ public IteratorResultIterator readBatch() throws IOException {
             IteratorWithException<InternalRow, IOException> iterator =
                     new AvroBlockIterator(reader.getBlockCount(), reader);
             return new IteratorResultIterator(
-                    iterator, () -> pool.recycler().recycle(ticket), filePath, rowPosition, false);
+                    iterator, () -> pool.recycler().recycle(ticket), filePath, rowPosition);
         }
 
         private boolean readNextBlock() throws IOException {

diff --git a/paimon-format/src/main/java/org/apache/paimon/format/orc/OrcReaderFactory.java b/paimon-format/src/main/java/org/apache/paimon/format/orc/OrcReaderFactory.java
@@ -170,7 +170,7 @@ protected OrcReaderBatch(
             this.paimonColumnBatch = paimonColumnBatch;
             this.result =
                     new ColumnarRowIterator(
-                            filePath, new ColumnarRow(paimonColumnBatch), this::recycle, true);
+                            filePath, new ColumnarRow(paimonColumnBatch), this::recycle);
         }
 
         /**