diff --git a/server/cluster/cluster.go b/server/cluster/cluster.go index 411a37a0443..51389e48e93 100644 --- a/server/cluster/cluster.go +++ b/server/cluster/cluster.go @@ -2326,11 +2326,9 @@ func (c *RaftCluster) SetMinResolvedTS(storeID, minResolvedTS uint64) error { return errs.ErrStoreNotFound.FastGenByArgs(storeID) } - newStore := store.Clone( - core.SetMinResolvedTS(minResolvedTS), - ) - - return c.putStoreLocked(newStore) + newStore := store.Clone(core.SetMinResolvedTS(minResolvedTS)) + c.core.PutStore(newStore) + return nil } func (c *RaftCluster) checkAndUpdateMinResolvedTS() (uint64, bool) {