From d2ce1758c94563ffc37f4b43cebc9450e14c6627 Mon Sep 17 00:00:00 2001 From: Jianyuan Jiang Date: Wed, 6 Dec 2023 10:47:26 +0800 Subject: [PATCH] Update cdc/puller/puller.go Co-authored-by: dongmen <20351731+asddongmen@users.noreply.github.com> --- cdc/puller/puller.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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 }