diff --git a/dm/syncer/syncer.go b/dm/syncer/syncer.go index b1ac38f52da..212a3fa9bb1 100644 --- a/dm/syncer/syncer.go +++ b/dm/syncer/syncer.go @@ -1218,7 +1218,7 @@ func (s *Syncer) afterFlushCheckpoint(task *checkpointFlushTask) error { s.tctx.L().Info("after async flushed checkpoint, gc stale causality keys", zap.Int64("flush job seq", task.asyncflushJob.flushSeq)) s.addJob(newGCJob(task.asyncflushJob.flushSeq)) } else { - s.tctx.L().Info("after async flushed checkpoint, gc all causality keys") + s.tctx.L().Info("after sync flushed checkpoint, gc all causality keys") s.addJob(newGCJob(math.MaxInt64)) }