1

matrixorigin · Jun 25, 2024 · ff36194 · ff36194
1 parent 9f00245
commit ff36194
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/sql/compile/scope.go b/pkg/sql/compile/scope.go
@@ -1257,7 +1257,7 @@ func (s *Scope) sendNotifyMessage(wg *sync.WaitGroup, resultChan chan notifyMess
 				message.NeedNotReply = false
 				message.Uuid = uuid
 
-				if errSend := sender.streamSender.Send(s.Proc.Ctx, message); errSend != nil {
+				if errSend := sender.streamSender.Send(sender.ctx, message); errSend != nil {
 					closeWithError(errSend, s.Proc.Reg.MergeReceivers[receiverIdx], sender)
 					return
 				}