diff --git a/server/schedulers/balance_leader.go b/server/schedulers/balance_leader.go index 8d7963913ff..2052085c150 100644 --- a/server/schedulers/balance_leader.go +++ b/server/schedulers/balance_leader.go @@ -166,7 +166,8 @@ func (l *balanceLeaderScheduler) createOperator(region *core.RegionInfo, source, } schedulerCounter.WithLabelValues(l.GetName(), "new_operator").Inc() - balanceLeaderCounter.WithLabelValues("move_leader", fmt.Sprintf("store%d-to-store%d", source.GetId(), target.GetId())).Inc() + balanceLeaderCounter.WithLabelValues("move_leader", fmt.Sprintf("store%d-out", source.GetId())).Inc() + balanceLeaderCounter.WithLabelValues("move_leader", fmt.Sprintf("store%d-in", target.GetId())).Inc() step := schedule.TransferLeader{FromStore: region.Leader.GetStoreId(), ToStore: target.GetId()} op := schedule.NewOperator("balance-leader", region.GetId(), schedule.OpBalance|schedule.OpLeader, step) return []*schedule.Operator{op} diff --git a/server/schedulers/balance_region.go b/server/schedulers/balance_region.go index 3f3fdca73e5..9d354e376bd 100644 --- a/server/schedulers/balance_region.go +++ b/server/schedulers/balance_region.go @@ -161,6 +161,7 @@ func (s *balanceRegionScheduler) transferPeer(cluster schedule.Cluster, region * schedulerCounter.WithLabelValues(s.GetName(), "no_peer").Inc() return nil } - balanceRegionCounter.WithLabelValues("move_peer", fmt.Sprintf("store%d-to-store%d", source.GetId(), target.GetId())).Inc() + balanceRegionCounter.WithLabelValues("move_peer", fmt.Sprintf("store%d-out", source.GetId())).Inc() + balanceRegionCounter.WithLabelValues("move_peer", fmt.Sprintf("store%d-in", target.GetId())).Inc() return schedule.CreateMovePeerOperator("balance-region", cluster, region, schedule.OpBalance, oldPeer.GetStoreId(), newPeer.GetStoreId(), newPeer.GetId()) }