From 8af92802f9c533fabbe0a0e6bce8add0d8affa34 Mon Sep 17 00:00:00 2001 From: Ti Chi Robot Date: Mon, 28 Feb 2022 13:01:44 +0800 Subject: [PATCH] syncer(dm): Fix async flush log message (#4500) (#4513) ref pingcap/tiflow#4287 --- dm/syncer/syncer.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dm/syncer/syncer.go b/dm/syncer/syncer.go index c770a4c15e8..27eec5d04de 100644 --- a/dm/syncer/syncer.go +++ b/dm/syncer/syncer.go @@ -1194,7 +1194,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.dmlJobCh <- 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.dmlJobCh <- newGCJob(math.MaxInt64) }