We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 04ccf4b commit ab5a43fCopy full SHA for ab5a43f
pkg/kv/kvserver/allocator/mmaprototype/allocator_state.go
@@ -673,6 +673,12 @@ func (a *allocatorState) rebalanceStores(
673
// Also exclude all stores on nodes that have existing replicas.
674
for _, replica := range rstate.replicas {
675
storeID := replica.StoreID
676
+ if storeID == store.StoreID {
677
+ // We don't exclude other stores on this node, since we are allowed to
678
+ // transfer the range to them. If the node is overloaded or not fdOK,
679
+ // we have already excluded those stores above.
680
+ continue
681
+ }
682
nodeID := a.cs.stores[storeID].NodeID
683
for _, storeID := range a.cs.nodes[nodeID].stores {
684
storesToExcludeForRange.insert(storeID)
0 commit comments