loader: fix wrong progress in query-status for loader (#4093) (#4143)

close #3252
pingcap · Dec 30, 2021 · 1bc0c48 · 1bc0c48
1 parent e73e411
commit 1bc0c48
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/dm/loader/loader.go b/dm/loader/loader.go
@@ -222,7 +222,7 @@ func (w *Worker) run(ctx context.Context, fileJobQueue chan *fileJob, runFatalCh
 				continue
 			}
 			// update finished offset after checkpoint updated
-			w.loader.finishedDataSize.Store(job.offset)
+			w.loader.finishedDataSize.Add(job.offset - job.lastOffset)
 			if _, ok := w.loader.dbTableDataFinishedSize[job.sourceSchema]; ok {
 				if _, ok := w.loader.dbTableDataFinishedSize[job.sourceSchema][job.sourceTable]; ok {
 					w.loader.dbTableDataFinishedSize[job.sourceSchema][job.sourceTable].Store(job.offset)