From b14e42ec273b12e7499dc702660093a8feaec2eb Mon Sep 17 00:00:00 2001 From: jiangjianyuan Date: Wed, 6 Dec 2023 11:07:13 +0800 Subject: [PATCH] fix stuck detect issue --- cdc/puller/puller.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/cdc/puller/puller.go b/cdc/puller/puller.go index 80cb39b5d65..dda87b9e704 100644 --- a/cdc/puller/puller.go +++ b/cdc/puller/puller.go @@ -284,8 +284,8 @@ func (p *pullerImpl) detectResolvedTsStuck() error { if p.cfg.Debug.Puller.EnableResolvedTsStuckDetection { resolvedTs := p.tsTracker.Frontier() // 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 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 }