From 51f13a8ad272657149ca3c86e8bf70c5d9a36387 Mon Sep 17 00:00:00 2001 From: walter Date: Wed, 22 May 2024 14:16:15 +0800 Subject: [PATCH] Fix job progress key time point (#80) --- pkg/ccr/job_progress.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 }