address comments

Signed-off-by: Ryan Leung <[email protected]>
tikv · Sep 12, 2019 · e3179c6 · e3179c6
1 parent 9923de6
commit e3179c6
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/server/schedule/filter/filters.go b/server/schedule/filter/filters.go
@@ -26,7 +26,7 @@ import (
 
 // Filter is an interface to filter source and target store.
 type Filter interface {
-	// ActOn is used to indicate that the filter will act on.
+	// ActOn is used to indicate where the filter will act on.
 	ActOn() string
 	Type() string
 	// Return true if the store should not be used as a source store.

diff --git a/server/schedule/filter/metrics.go b/server/schedule/filter/metrics.go
@@ -22,7 +22,7 @@ var (
 			Subsystem: "schedule",
 			Name:      "filter",
 			Help:      "Counter of the filter",
-		}, []string{"action", "address", "store", "acton", "type"})
+		}, []string{"action", "address", "store", "act-on", "type"})
 )
 
 func init() {

diff --git a/server/schedulers/adjacent_region.go b/server/schedulers/adjacent_region.go
@@ -97,7 +97,7 @@ func (a *adjacentState) len() int {
 // on each store.
 func newBalanceAdjacentRegionScheduler(opController *schedule.OperatorController, args ...uint64) schedule.Scheduler {
 	filters := []filter.Filter{
-		filter.StoreStateFilter{Act: balanceAdjacentRegionSchedulerName, MoveRegion: true},
+		filter.StoreStateFilter{Act: balanceAdjacentRegionSchedulerName, TransferLeader: true, MoveRegion: true},
 	}
 	base := newBaseScheduler(opController)
 	s := &balanceAdjacentRegionScheduler{