executor: AnalyzePartitionConcurrency is not more than number of task

Signed-off-by: Weizhen Wang <wangweizhen@pingcap.com>
pingcap · Oct 8, 2023 · ff2f8c4 · ff2f8c4
1 parent 869c425
commit ff2f8c4
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/executor/analyze.go b/executor/analyze.go
@@ -355,6 +355,8 @@ func (e *AnalyzeExec) handleResultsError(
 	resultsCh <-chan *statistics.AnalyzeResults,
 ) error {
 	partitionStatsConcurrency := e.Ctx().GetSessionVars().AnalyzePartitionConcurrency
+	// the concurrency of handleResultsError cannot be more than partitionStatsConcurrency
+	partitionStatsConcurrency = min(concurrency, partitionStatsConcurrency)
 	// If partitionStatsConcurrency > 1, we will try to demand extra session from Domain to save Analyze results in concurrency.
 	// If there is no extra session we can use, we will save analyze results in single-thread.
 	if partitionStatsConcurrency > 1 {