diff options
| -rw-r--r-- | exec/java-exec/src/main/java/parquet/hadoop/ColumnChunkIncReadStore.java | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/exec/java-exec/src/main/java/parquet/hadoop/ColumnChunkIncReadStore.java b/exec/java-exec/src/main/java/parquet/hadoop/ColumnChunkIncReadStore.java index 2a3124c9c..f2fe3762c 100644 --- a/exec/java-exec/src/main/java/parquet/hadoop/ColumnChunkIncReadStore.java +++ b/exec/java-exec/src/main/java/parquet/hadoop/ColumnChunkIncReadStore.java @@ -144,7 +144,9 @@ public class ColumnChunkIncReadStore implements PageReadStore { ByteBuf buf = allocator.buffer(pageHeader.compressed_page_size); lastPage = buf; ByteBuffer buffer = buf.nioBuffer(0, pageHeader.compressed_page_size); - CompatibilityUtil.getBuf(in, buffer, pageHeader.compressed_page_size); + while (buffer.remaining() > 0) { + CompatibilityUtil.getBuf(in, buffer, pageHeader.compressed_page_size); + } return new Page( decompressor.decompress(BytesInput.from(buffer, 0, pageHeader.compressed_page_size), pageHeader.getUncompressed_page_size()), pageHeader.data_page_header.num_values, |