diff --git a/src/io/parquet/read/deserialize/nested_utils.rs b/src/io/parquet/read/deserialize/nested_utils.rs index d7851f76e05..9d9fe723306 100644 --- a/src/io/parquet/read/deserialize/nested_utils.rs +++ b/src/io/parquet/read/deserialize/nested_utils.rs @@ -455,7 +455,7 @@ fn extend_offsets2<'a, D: NestedDecoder<'a>>( let next_rep = page.iter.peek().map(|x| x.0).unwrap_or(0); - if next_rep == 0 && rows == additional.saturating_add(1) { + if next_rep == 0 && rows == additional { break; } }