diff --git a/cdc/kv/region_worker.go b/cdc/kv/region_worker.go index 2246ed9246b..457313fbd61 100644 --- a/cdc/kv/region_worker.go +++ b/cdc/kv/region_worker.go @@ -749,7 +749,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("changefeed", w.session.client.changefeed), zap.String("EventType", "RESOLVED"), zap.Uint64("resolvedTs", resolvedTs),