loader: fix wrong progress in query-status for loader (pingcap#4093) (p…

…ingcap#4143) close pingcap#3252
ti-chi-bot · Jan 13, 2022 · 8e1aaab · 8e1aaab
1 parent 1ba5290
commit 8e1aaab
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)