Skip to content

Commit 1bff600

Browse files
committed
update
1 parent 02f363d commit 1bff600

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

src/runtime/streaming/operators/grouping/incremental_aggregate.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -70,7 +70,7 @@ impl BatchData {
7070
}
7171

7272
fn dec(&mut self) {
73-
self.count = self.count.checked_sub(1).unwrap_or_default();
73+
self.count = self.count.saturating_sub(1);
7474
self.generation += 1;
7575
}
7676
}

0 commit comments

Comments
 (0)