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

close #3252
pingcap · Dec 29, 2021 · b508bc1 · b508bc1
1 parent 2bd7c92
commit b508bc1
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)