diff --git a/cdc/puller/puller.go b/cdc/puller/puller.go index 11c5003d94c..09c30f6cd51 100644 --- a/cdc/puller/puller.go +++ b/cdc/puller/puller.go @@ -254,7 +254,9 @@ func (p *pullerImpl) Run(ctx context.Context) error { func (p *pullerImpl) detectResolvedTsStuck() error { if p.cfg.Debug.Puller.EnableResolvedTsStuckDetection { resolvedTs := p.tsTracker.Frontier() - // check if the resolvedTs is advanced before + // check if the resolvedTs is advancing, + // If the resolvedTs in Frontier is less than startResolvedTs, it means that the incremental scan has + // not complete yet. We need to make no decision in this scenario. if resolvedTs <= p.startResolvedTs { return nil }