Do not try to uncompress pages that are not compressed

panther-labs · Mar 27, 2024 · 1ba8c9a · 1ba8c9a
1 parent 0c50c9d
commit 1ba8c9a
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/page_v2.go b/page_v2.go
@@ -122,6 +122,10 @@ func (dp *dataPageReaderV2) read(r io.Reader, ph *parquet.PageHeader, codec parq
 		}
 	}
 
+	if !ph.DataPageHeaderV2.IsCompressed {
+		return dp.valuesDecoder.init(bytes.NewReader(dataPageBlock[levelsSize:]))
+	}
+
 	reader, err := newBlockReader(dataPageBlock[levelsSize:], codec, ph.GetCompressedPageSize()-levelsSize, ph.GetUncompressedPageSize()-levelsSize, dp.alloc)
 	if err != nil {
 		return err