diff --git a/src/io/parquet/read/row_group.rs b/src/io/parquet/read/row_group.rs index 754b3528bb0..fea9638e5e2 100644 --- a/src/io/parquet/read/row_group.rs +++ b/src/io/parquet/read/row_group.rs @@ -78,10 +78,11 @@ impl Iterator for RowGroupDeserializer { }) .collect::>>() .map(Chunk::new); - self.remaining_rows = self.remaining_rows.saturating_sub(chunk - .as_ref() - .map(|x| x.len()) - .unwrap_or(self.remaining_rows) + self.remaining_rows = self.remaining_rows.saturating_sub( + chunk + .as_ref() + .map(|x| x.len()) + .unwrap_or(self.remaining_rows), ); Some(chunk)