From 3134f9475b16941246ae9ac542fa5e12ae54e388 Mon Sep 17 00:00:00 2001 From: "collaborate.edit@gmail.com" Date: Thu, 3 Feb 2022 22:55:05 -0500 Subject: [PATCH] Fix async flush log message --- 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 763d90efefb..718f9b531ef 100644 --- a/dm/syncer/syncer.go +++ b/dm/syncer/syncer.go @@ -1226,7 +1226,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)) }