executor: fix index_lookup_hash_join hang when used with limit (pingc…

…ap#35820) (pingcap#36104) close pingcap#35638
ti-srebot · Jul 14, 2022 · 6e9fd42 · 6e9fd42
1 parent c82d6d7
commit 6e9fd42
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/executor/index_lookup_hash_join.go b/executor/index_lookup_hash_join.go
@@ -608,7 +608,10 @@ func (iw *indexHashJoinInnerWorker) handleTask(ctx context.Context, task *indexH
 		if task.keepOuterOrder {
 			if err != nil {
 				joinResult.err = err
-				resultCh <- joinResult
+				select {
+				case <-ctx.Done():
+				case resultCh <- joinResult:
+				}
 			}
 			close(resultCh)
 		}