From fb1db61286100e3b9878f8e45ba625dba623a60a Mon Sep 17 00:00:00 2001 From: "Jorge C. Leitao" Date: Wed, 13 Apr 2022 04:11:47 +0000 Subject: [PATCH] Fixed bug in reading binary parquet --- src/io/parquet/read/deserialize/binary/basic.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/io/parquet/read/deserialize/binary/basic.rs b/src/io/parquet/read/deserialize/binary/basic.rs index 6b0b8f1bd9a..32f491d0b37 100644 --- a/src/io/parquet/read/deserialize/binary/basic.rs +++ b/src/io/parquet/read/deserialize/binary/basic.rs @@ -220,7 +220,7 @@ impl<'a, O: Offset> utils::Decoder<'a> for BinaryDecoder { page_values, ), State::Required(page) => { - page.remaining -= additional; + page.remaining = page.remaining.saturating_sub(additional); for x in page.values.by_ref().take(additional) { values.push(x) }