Skip to content

Commit b2c689e

Browse files
committed
use ads_diff avoid overflow
1 parent e807877 commit b2c689e

File tree

1 file changed

+10
-3
lines changed

1 file changed

+10
-3
lines changed

src/query/storages/fuse/fuse/src/operations/mutation/mutation_sink.rs

Lines changed: 10 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -160,9 +160,16 @@ impl Processor for MutationSink {
160160
State::ReadMeta(input_meta) => {
161161
let meta = MutationMeta::from_meta(&input_meta)?;
162162

163-
let affect_rows = self.base_snapshot.summary.row_count - meta.summary.row_count;
164-
let affect_bytes = self.base_snapshot.summary.uncompressed_byte_size
165-
- meta.summary.uncompressed_byte_size;
163+
let affect_rows = self
164+
.base_snapshot
165+
.summary
166+
.row_count
167+
.abs_diff(meta.summary.row_count);
168+
let affect_bytes = self
169+
.base_snapshot
170+
.summary
171+
.uncompressed_byte_size
172+
.abs_diff(meta.summary.uncompressed_byte_size);
166173
let progress_values = ProgressValues {
167174
rows: affect_rows as usize,
168175
bytes: affect_bytes as usize,

0 commit comments

Comments
 (0)