ticdc:Fix too much unnecessary log for lastSyncedTs (#10667) (#10683)

close #10289
pingcap · Mar 1, 2024 · 988f039 · 988f039
1 parent 81a35bf
commit 988f039
Showing 1 changed file with 9 additions and 6 deletions.
diff --git a/cdc/owner/changefeed.go b/cdc/owner/changefeed.go
@@ -385,12 +385,15 @@ func (c *changefeed) tick(ctx cdcContext.Context, captures map[model.CaptureID]*
 	if err != nil {
 		return errors.Trace(err)
 	}
-	if c.lastSyncedTs < watermark.LastSyncedTs {
-		c.lastSyncedTs = watermark.LastSyncedTs
-	} else if c.lastSyncedTs > watermark.LastSyncedTs {
-		log.Warn("LastSyncedTs should not be greater than newLastSyncedTs",
-			zap.Uint64("c.LastSyncedTs", c.lastSyncedTs),
-			zap.Uint64("newLastSyncedTs", watermark.LastSyncedTs))
+
+	if watermark.LastSyncedTs != scheduler.CheckpointCannotProceed {
+		if c.lastSyncedTs < watermark.LastSyncedTs {
+			c.lastSyncedTs = watermark.LastSyncedTs
+		} else if c.lastSyncedTs > watermark.LastSyncedTs {
+			log.Warn("LastSyncedTs should not be greater than newLastSyncedTs",
+				zap.Uint64("c.LastSyncedTs", c.lastSyncedTs),
+				zap.Uint64("newLastSyncedTs", watermark.LastSyncedTs))
+		}
 	}
 
 	if watermark.PullerResolvedTs != scheduler.CheckpointCannotProceed && watermark.PullerResolvedTs != math.MaxUint64 {