Skip to content

Commit a030383

Browse files
committed
fix conflict
Signed-off-by: Cabinfever_B <cabinfeveroier@gmail.com>
1 parent 0f57c1b commit a030383

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

server/schedule/region_scatterer.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -318,7 +318,7 @@ func (r *RegionScatterer) scatterRegion(region *core.RegionInfo, group string) *
318318
continue
319319
}
320320
for {
321-
candidates := r.selectCandidates(region, oldFit, peer.GetStoreId(), selectedStores, context)
321+
candidates := r.selectCandidates(region, peer.GetStoreId(), selectedStores, context)
322322
newPeer := r.selectStore(group, peer, peer.GetStoreId(), candidates, context)
323323
targetPeers[newPeer.GetStoreId()] = newPeer
324324
selectedStores[newPeer.GetStoreId()] = struct{}{}
@@ -402,7 +402,7 @@ func isSameDistribution(region *core.RegionInfo, targetPeers map[uint64]*metapb.
402402
return region.GetLeader().GetStoreId() == targetLeader
403403
}
404404

405-
func (r *RegionScatterer) selectCandidates(region *core.RegionInfo, oldFit *placement.RegionFit, sourceStoreID uint64, selectedStores map[uint64]struct{}, context engineContext) []uint64 {
405+
func (r *RegionScatterer) selectCandidates(region *core.RegionInfo, sourceStoreID uint64, selectedStores map[uint64]struct{}, context engineContext) []uint64 {
406406
sourceStore := r.cluster.GetStore(sourceStoreID)
407407
if sourceStore == nil {
408408
log.Error("failed to get the store", zap.Uint64("store-id", sourceStoreID), errs.ZapError(errs.ErrGetSourceStore))

0 commit comments

Comments
 (0)