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

…1029)
tikv · Apr 17, 2018 · 59c5466 · 59c5466
1 parent d80dad6
commit 59c5466
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 {