Skip to content

Commit

Permalink
syncer(dm): Fix async flush log message (#4500) (#4513)
Browse files Browse the repository at this point in the history
ref #4287
  • Loading branch information
ti-chi-bot authored Feb 28, 2022
1 parent 7defc78 commit 8af9280
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 @@ -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)
}

Expand Down

0 comments on commit 8af9280

Please sign in to comment.