diff --git a/pkg/ccr/job_progress.go b/pkg/ccr/job_progress.go
index d58468c3..773192d7 100644
--- a/pkg/ccr/job_progress.go
+++ b/pkg/ccr/job_progress.go
@@ -270,7 +270,7 @@ func (j *JobProgress) NextWithPersist(commitSeq int64, syncState SyncState, subS
 		j.FullSyncStartAt = time.Now().Unix()
 		j.IncrementalSyncStartAt = 0
 		j.IngestBinlogAt = 0
-	} else if subSyncState == Done && (syncState == TableIncrementalSync || syncState == TableIncrementalSync) {
+	} else if subSyncState == Done && (syncState == TableIncrementalSync || syncState == DBIncrementalSync) {
 		j.IncrementalSyncStartAt = time.Now().Unix()
 		j.IngestBinlogAt = 0
 	}