Skip to content

Commit 6171842

Browse files
authored
kvclient(ticdc): fix the resolve last run status gc (#12188)
close #12187
1 parent 4f50e2f commit 6171842

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

cdc/kv/shared_client.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -776,7 +776,7 @@ func (s *SharedClient) handleResolveLockTasks(ctx context.Context) error {
776776
now := time.Now()
777777
for regionID, lastRun := range resolveLastRun {
778778
if now.Sub(lastRun) < resolveLockMinInterval {
779-
resolveLastRun[regionID] = lastRun
779+
copied[regionID] = lastRun
780780
}
781781
}
782782
resolveLastRun = copied

0 commit comments

Comments
 (0)