diff --git a/pkg/schedule/checker/rule_checker.go b/pkg/schedule/checker/rule_checker.go index e09c008626d..08ef5f7b45c 100644 --- a/pkg/schedule/checker/rule_checker.go +++ b/pkg/schedule/checker/rule_checker.go @@ -483,10 +483,7 @@ func (c *RuleChecker) fixOrphanPeers(region *core.RegionInfo, fit *placement.Reg checkDownPeer := func(peers []*metapb.Peer) (*metapb.Peer, bool) { for _, p := range peers { - if isInDisconnectedStore(p) { - return p, true - } - if isDownPeer(p.GetId()) { + if isInDisconnectedStore(p) || isDownPeer(p.GetId()) { return p, true } if isPendingPeer(p.GetId()) {