executor: reduce the length of channel to avoid OOM (#47540)

ref #47275
pingcap · Oct 11, 2023 · 68b5788 · 68b5788
1 parent aa99c16
commit 68b5788
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/executor/analyze.go b/executor/analyze.go
@@ -109,7 +109,8 @@ func (e *AnalyzeExec) Next(ctx context.Context, _ *chunk.Chunk) error {
 
 	// Start workers with channel to collect results.
 	taskCh := make(chan *analyzeTask, concurrency)
-	resultsCh := make(chan *statistics.AnalyzeResults, len(tasks))
+	resultChLen := min(concurrency*2, len(tasks))
+	resultsCh := make(chan *statistics.AnalyzeResults, resultChLen)
 	for i := 0; i < concurrency; i++ {
 		e.wg.Run(func() { e.analyzeWorker(taskCh, resultsCh) })
 	}