From 87488312a1b57341a9174c043a3ba0ad6a120266 Mon Sep 17 00:00:00 2001 From: qupeng Date: Mon, 18 Jul 2022 13:47:37 +0800 Subject: [PATCH] cdc: ignore redo meta regress for restarting Signed-off-by: qupeng --- cdc/redo/writer/writer.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/cdc/redo/writer/writer.go b/cdc/redo/writer/writer.go index b5343bf6ebc..6d18ff2b893 100644 --- a/cdc/redo/writer/writer.go +++ b/cdc/redo/writer/writer.go @@ -514,7 +514,7 @@ 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)) } @@ -522,7 +522,7 @@ func (l *LogWriter) maybeUpdateMeta(checkpointTs, resolvedTs uint64) ([]byte, er 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)) }