diff --git a/pkg/schedule/coordinator.go b/pkg/schedule/coordinator.go index 3708acf12a78..ece4162a7c95 100644 --- a/pkg/schedule/coordinator.go +++ b/pkg/schedule/coordinator.go @@ -160,7 +160,7 @@ func (c *Coordinator) PatrolRegions() { defer ticker.Stop() workersCount := c.cluster.GetCheckerConfig().GetPatrolRegionConcurrency() - regionChan := make(chan *core.RegionInfo, c.cluster.GetCheckerConfig().GetPatrolRegionConcurrency()) + regionChan := make(chan *core.RegionInfo, 65536) quit := make(chan bool) var wg sync.WaitGroup c.startPatrolRegionWorkers(workersCount, regionChan, quit, &wg)