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

…ap#35820) (pingcap#36102) close pingcap#35638
ti-srebot · Jul 14, 2022 · ef81f12 · ef81f12
1 parent 124887c
commit ef81f12
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
@@ -626,7 +626,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)
  }