fix

apache · Aug 1, 2024 · cc33525 · cc33525
1 parent a38d6ce
commit cc33525
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/paimon-common/src/main/java/org/apache/paimon/reader/RecordReaderIterator.java b/paimon-common/src/main/java/org/apache/paimon/reader/RecordReaderIterator.java
@@ -19,6 +19,7 @@
 package org.apache.paimon.reader;
 
 import org.apache.paimon.utils.CloseableIterator;
+import org.apache.paimon.utils.IOUtils;
 
 import java.io.IOException;
 
@@ -34,7 +35,8 @@ public RecordReaderIterator(RecordReader<T> reader) {
         this.reader = reader;
         try {
             this.currentIterator = reader.readBatch();
-        } catch (IOException e) {
+        } catch (Exception e) {
+            IOUtils.closeQuietly(reader);
             throw new RuntimeException(e);
         }
         this.advanced = false;