executor: reduce the length of channel to avoid OOM

Signed-off-by: Weizhen Wang <[email protected]>
pingcap · Oct 11, 2023 · c16fd69 · c16fd69
1 parent ec2731b
commit c16fd69
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/executor/analyze.go b/executor/analyze.go
@@ -112,7 +112,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) })
 	}