Skip to content

Commit

Permalink
fix stuck detect issue
Browse files Browse the repository at this point in the history
  • Loading branch information
sdojjy authored and ti-chi-bot committed Dec 6, 2023
1 parent d2ce175 commit 5f6f052
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions cdc/puller/puller.go
Original file line number Diff line number Diff line change
Expand Up @@ -255,8 +255,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
}
Expand Down

0 comments on commit 5f6f052

Please sign in to comment.