Skip to content

Commit

Permalink
cdc: ignore redo meta regress for restarting
Browse files Browse the repository at this point in the history
Signed-off-by: qupeng <qupeng@pingcap.com>
  • Loading branch information
hicqu committed Jul 18, 2022
1 parent 8cd1cd3 commit 8748831
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions cdc/redo/writer/writer.go
Original file line number Diff line number Diff line change
Expand Up @@ -514,15 +514,15 @@ func (l *LogWriter) maybeUpdateMeta(checkpointTs, resolvedTs uint64) ([]byte, er
l.meta.CheckpointTs = checkpointTs
hasChange = true
} else if checkpointTs > 0 && checkpointTs != l.meta.CheckpointTs {
log.Warn("flushLogMeta with a regressed checkpoint ts, skip",
log.Warn("flushLogMeta with a regressed checkpoint ts, ignore",
zap.Uint64("currCheckpointTs", l.meta.CheckpointTs),
zap.Uint64("recvCheckpointTs", checkpointTs))
}
if resolvedTs > l.meta.ResolvedTs {
l.meta.ResolvedTs = resolvedTs
hasChange = true
} else if resolvedTs > 0 && resolvedTs != l.meta.ResolvedTs {
log.Warn("flushLogMeta with a regressed resolved ts, skip",
log.Warn("flushLogMeta with a regressed resolved ts, ignore",
zap.Uint64("currCheckpointTs", l.meta.ResolvedTs),
zap.Uint64("recvCheckpointTs", resolvedTs))
}
Expand Down

0 comments on commit 8748831

Please sign in to comment.