From c45664b8601cde28a1cd56e88a04bb4485c19f14 Mon Sep 17 00:00:00 2001 From: guo-shaoge Date: Mon, 11 Jul 2022 19:41:05 +0800 Subject: [PATCH] cherry pick #35820 to release-5.3 Signed-off-by: ti-srebot --- executor/index_lookup_hash_join.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/executor/index_lookup_hash_join.go b/executor/index_lookup_hash_join.go index 65ec964ed2d55..9c16d1958493f 100644 --- a/executor/index_lookup_hash_join.go +++ b/executor/index_lookup_hash_join.go @@ -627,7 +627,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) }