diff --git a/parquet-column/src/main/java/org/apache/parquet/column/impl/ColumnReaderImpl.java b/parquet-column/src/main/java/org/apache/parquet/column/impl/ColumnReaderImpl.java index 8c2a4bf2eb..3fc327e3d9 100644 --- a/parquet-column/src/main/java/org/apache/parquet/column/impl/ColumnReaderImpl.java +++ b/parquet-column/src/main/java/org/apache/parquet/column/impl/ColumnReaderImpl.java @@ -150,7 +150,7 @@ public double getDouble() { private int dictionaryId; private long endOfPageValueCount; - private int readValues = 0; + private long readValues = 0; private int pageValueCount = 0; private final PrimitiveConverter converter; @@ -352,8 +352,8 @@ public ColumnReaderImpl(ColumnDescriptor path, PageReader pageReader, PrimitiveC this.dictionary = null; } this.totalValueCount = pageReader.getTotalValueCount(); - if (totalValueCount == 0) { - throw new ParquetDecodingException("totalValueCount == 0"); + if (totalValueCount <= 0) { + throw new ParquetDecodingException("totalValueCount '" + totalValueCount + "' <= 0"); } consume(); } diff --git a/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/ColumnChunkPageReadStore.java b/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/ColumnChunkPageReadStore.java index af067474f8..4787b241fb 100644 --- a/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/ColumnChunkPageReadStore.java +++ b/parquet-hadoop/src/main/java/org/apache/parquet/hadoop/ColumnChunkPageReadStore.java @@ -63,7 +63,7 @@ static final class ColumnChunkPageReader implements PageReader { this.decompressor = decompressor; this.compressedPages = new LinkedList(compressedPages); this.compressedDictionaryPage = compressedDictionaryPage; - int count = 0; + long count = 0; for (DataPage p : compressedPages) { count += p.getValueCount(); }