From dea207bcc1da411a382b9c9cb8f877265abc5c40 Mon Sep 17 00:00:00 2001 From: guo-shaoge Date: Thu, 1 Dec 2022 11:28:00 +0800 Subject: [PATCH] executor: fix index merge intersection may stuck (#39495) --- executor/index_merge_reader.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/executor/index_merge_reader.go b/executor/index_merge_reader.go index d7475f71374b8..5bf0a15a6d7f8 100644 --- a/executor/index_merge_reader.go +++ b/executor/index_merge_reader.go @@ -950,11 +950,12 @@ func (w *indexMergeProcessWorker) fetchLoopIntersection(ctx context.Context, fet }, w.handleLoopFetcherPanic(ctx, resultCh, "IndexMergeIntersectionProcessWorker", errCh)) workers = append(workers, worker) } +loop: for task := range fetchCh { select { case workers[task.parTblIdx%workerCnt].workerCh <- task: case <-errCh: - break + break loop } } for _, processWorker := range workers {