diff --git a/cdc/kv/region_worker.go b/cdc/kv/region_worker.go index 474b4364af3..f579821726b 100644 --- a/cdc/kv/region_worker.go +++ b/cdc/kv/region_worker.go @@ -744,7 +744,7 @@ func (w *regionWorker) handleResolvedTs( } if resolvedTs < state.lastResolvedTs { - log.Warn("The resolvedTs is fallen back in kvclient", + log.Debug("The resolvedTs is fallen back in kvclient", zap.String("EventType", "RESOLVED"), zap.Uint64("resolvedTs", resolvedTs), zap.Uint64("lastResolvedTs", state.lastResolvedTs),