fix

pingcap · Aug 7, 2023 · dd25a82 · dd25a82
1 parent 6ad49e7
commit dd25a82
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/executor/index_lookup_join.go b/executor/index_lookup_join.go
@@ -189,9 +189,10 @@ func (e *IndexLookUpJoin) startWorkers(ctx context.Context) {
 	innerCh := make(chan *lookUpJoinTask, concurrency)
 	e.workerWg.Add(1)
 	go e.newOuterWorker(resultCh, innerCh).run(workerCtx, e.workerWg)
-	e.workerWg.Add(concurrency)
 	for i := 0; i < concurrency; i++ {
-		go e.newInnerWorker(innerCh).run(workerCtx, e.workerWg)
+		innerWorker := e.newInnerWorker(innerCh)
+		e.workerWg.Add(1)
+		go innerWorker.run(workerCtx, e.workerWg)
 	}
 }