From 7b85640bd14172aee5e4c6f28a5031cbda0a03b5 Mon Sep 17 00:00:00 2001 From: dantin Date: Fri, 15 Sep 2017 18:18:58 +0800 Subject: [PATCH] revert limit logic --- server/coordinator.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/server/coordinator.go b/server/coordinator.go index ae7e1c7b16c..1c272050166 100644 --- a/server/coordinator.go +++ b/server/coordinator.go @@ -111,6 +111,11 @@ func (c *coordinator) dispatch(region *core.RegionInfo) { } } + // Check replica operator. + if c.limiter.operatorCount(core.RegionKind) >= c.opt.GetReplicaScheduleLimit() { + return + } + if op := c.checker.Check(region); op != nil { c.addOperator(op) }