From b0f52af9c3d805b0d90d421c24ea8c42c49391a8 Mon Sep 17 00:00:00 2001
From: will & database <87208113+db-will@users.noreply.github.com>
Date: Mon, 7 Feb 2022 06:57:34 -0500
Subject: [PATCH] syncer(dm): Fix async flush log message (#4500)

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 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))
 	}