scheduler: log all divergent routines when filtering the target store (…

…#1614) Signed-off-by: Shafreeck Sea <shafreeck@gmail.com>
tikv · Jul 4, 2019 · 0cbcd4c · 0cbcd4c
1 parent f0c5c9d
commit 0cbcd4c
Showing 1 changed file with 17 additions and 0 deletions.
diff --git a/server/schedulers/balance_region.go b/server/schedulers/balance_region.go
@@ -207,12 +207,29 @@ func (s *balanceRegionScheduler) hasPotentialTarget(cluster schedule.Cluster, re
 
 	for _, store := range cluster.GetStores() {
 		if schedule.FilterTarget(cluster, store, filters) {
+			log.Debug("skip target store by filters",
+				zap.String("scheduler", s.GetName()),
+				zap.Uint64("region", region.GetID()),
+				zap.Uint64("source", source.GetID()),
+				zap.Uint64("target", store.GetID()))
 			continue
 		}
 		if !store.IsUp() || store.DownTime() > cluster.GetMaxStoreDownTime() {
+			log.Debug("skip target store by status",
+				zap.String("scheduler", s.GetName()),
+				zap.Uint64("region", region.GetID()),
+				zap.Uint64("source", source.GetID()),
+				zap.Uint64("target", store.GetID()),
+				zap.Bool("isup", store.IsUp()),
+				zap.Duration("downtime", store.DownTime()))
 			continue
 		}
 		if !shouldBalance(cluster, source, store, region, core.RegionKind, opInfluence) {
+			log.Debug("skip target store for it should not balance",
+				zap.String("scheduler", s.GetName()),
+				zap.Uint64("region", region.GetID()),
+				zap.Uint64("source", source.GetID()),
+				zap.Uint64("target", store.GetID()))
 			continue
 		}
 		return true