Fixed bug in reading binary parquet

jorgecarleitao · Apr 13, 2022 · fb1db61 · fb1db61
1 parent 60130f4
commit fb1db61
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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<O> {
                 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)
                 }