diff --git a/ddl/backfilling_scheduler.go b/ddl/backfilling_scheduler.go index 8a9c238027..b955303a02 100644 --- a/ddl/backfilling_scheduler.go +++ b/ddl/backfilling_scheduler.go @@ -483,13 +483,11 @@ func (w *addIndexIngestWorker) HandleTask(rs idxRecResult) { result.totalCount = cnt result.nextKey = nextKey result.err = w.checkpointMgr.UpdateCurrent(rs.id, count) - count = cnt } else { result.addedCount = count result.scanCount = count result.nextKey = nextKey } - w.metricCounter.Add(float64(count)) if ResultCounterForTest != nil && result.err == nil { ResultCounterForTest.Add(1) }