Skip to content

Commit a78ef6a

Browse files
authored
fix(query): mysql affected_rows should use write process value (#10951)
1 parent d201ffb commit a78ef6a

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/query/service/src/servers/mysql/mysql_interactive_worker.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -468,7 +468,7 @@ impl ProgressReporter for ContextProgressReporter {
468468
}
469469

470470
fn affected_rows(&self) -> u64 {
471-
let progress = self.context.get_scan_progress_value();
471+
let progress = self.context.get_write_progress_value();
472472
progress.rows as u64
473473
}
474474
}

0 commit comments

Comments
 (0)