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) }