server: skip check a region if there is already a pending operator. (t…

…ikv#1029)
oh-my-tidb · May 7, 2018 · 2eacc5a · 2eacc5a
1 parent 9b824d2
commit 2eacc5a
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/server/coordinator.go b/server/coordinator.go
@@ -151,6 +151,11 @@ func (c *coordinator) patrolRegions() {
 		}
 
 		for _, region := range regions {
+			// Skip the region if there is already a pending operator.
+			if c.getOperator(region.GetId()) != nil {
+				continue
+			}
+
 			key = region.GetEndKey()
 
 			if op := c.namespaceChecker.Check(region); op != nil {