We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0f0c97b commit 805a121Copy full SHA for 805a121
driver/mysql/applier.go
@@ -1199,7 +1199,12 @@ func (a *Applier) updateDumpProgressLoop() {
1199
return
1200
}
1201
1202
- err = a.storeManager.PutDumpProgress(a.subject, a.TotalRowsReplayed, a.mysqlContext.RowsEstimate)
+ exec := a.TotalRowsReplayed
1203
+ total := a.mysqlContext.RowsEstimate
1204
+ if total < exec || a.stage == JobIncrCopy {
1205
+ total = exec
1206
+ }
1207
+ err = a.storeManager.PutDumpProgress(a.subject, exec, total)
1208
if err != nil {
1209
a.onError(common.TaskStateDead, err)
1210
0 commit comments