Skip to content

Commit

Permalink
Update cdc/puller/puller.go
Browse files Browse the repository at this point in the history
Co-authored-by: dongmen <[email protected]>
  • Loading branch information
sdojjy and asddongmen authored Dec 6, 2023
1 parent 1247e43 commit adc37f1
Showing 1 changed file with 3 additions and 1 deletion.
4 changes: 3 additions & 1 deletion cdc/puller/puller.go
Original file line number Diff line number Diff line change
Expand Up @@ -283,7 +283,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
}
Expand Down

0 comments on commit adc37f1

Please sign in to comment.