Skip to content

Commit

Permalink
syncer(dm): Fix async flush log message (#4500)
Browse files Browse the repository at this point in the history
ref #4287
  • Loading branch information
db-will authored Feb 7, 2022
1 parent 5c7d238 commit b0f52af
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion dm/syncer/syncer.go
Original file line number Diff line number Diff line change
Expand Up @@ -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))
}

Expand Down

0 comments on commit b0f52af

Please sign in to comment.