diff --git a/parquet/src/main/java/org/apache/iceberg/parquet/ParquetIO.java b/parquet/src/main/java/org/apache/iceberg/parquet/ParquetIO.java index d65b8d638edf..19d845e97bd0 100644 --- a/parquet/src/main/java/org/apache/iceberg/parquet/ParquetIO.java +++ b/parquet/src/main/java/org/apache/iceberg/parquet/ParquetIO.java @@ -166,9 +166,11 @@ public long defaultBlockSize() { private static class ParquetInputFile implements InputFile { private final org.apache.iceberg.io.InputFile file; + private org.apache.iceberg.io.SeekableInputStream icebergHadoopStream; private ParquetInputFile(org.apache.iceberg.io.InputFile file) { this.file = file; + this.icebergHadoopStream = null; } @Override @@ -178,7 +180,8 @@ public long getLength() throws IOException { @Override public SeekableInputStream newStream() throws IOException { - return stream(file.newStream()); + icebergHadoopStream = file.newStream(); + return stream(icebergHadoopStream); } } }