executor: fix index merge intersection may stuck (#39495)

pingcap · Dec 1, 2022 · dea207b · dea207b
1 parent fa7cf31
commit dea207b
Showing 1 changed file with 2 additions and 1 deletion.
diff --git 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 {