4

Signed-off-by: TONG, Zhigao <tongzhigao@pingcap.com>

pkg/executor/join/index_lookup_hash_join.go

@@ -78,6 +78,7 @@ type IndexNestedLoopHashJoin struct {
 	// panicErr records the error generated by panic recover. This is introduced to
 	// return the actual error message instead of `context cancelled` to the client.
 	panicErr struct {
+		sync.Mutex
 		atomic.Bool
 		error
 	}
@@ -198,8 +199,15 @@ func (e *IndexNestedLoopHashJoin) finishJoinWorkers(r any) {
 		if recoverdErr, ok := r.(error); ok {
 			err = recoverdErr
 		}
-		e.panicErr.error = err
-		e.panicErr.Store(true)
+
+		if !e.panicErr.Load() {
+			e.panicErr.Lock()
+			if !e.panicErr.Load() {
+				e.panicErr.error = err
+				e.panicErr.Store(true)
+			}
+			e.panicErr.Unlock()
+		}
 
 		if !e.KeepOuterOrder {
 			e.resultCh <- &indexHashJoinResult{err: err}