From b8f0ed8e3deaf77fcf1d1d929402517661508e7f Mon Sep 17 00:00:00 2001 From: yiguolei Date: Wed, 6 Sep 2023 15:15:01 +0800 Subject: [PATCH] [bugfix](datastreamsender) receiver will hang during close --- be/src/vec/sink/vdata_stream_sender.h | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/be/src/vec/sink/vdata_stream_sender.h b/be/src/vec/sink/vdata_stream_sender.h index 3e17170367adae..1097c000102a69 100644 --- a/be/src/vec/sink/vdata_stream_sender.h +++ b/be/src/vec/sink/vdata_stream_sender.h @@ -263,7 +263,10 @@ class VDataStreamSender::Channel { LOG(WARNING) << err; return Status::RpcError(err); } - return Status::OK(); + // If the rpc package send to receiver, but the receiver offer to the queue failed, then should + // return the error status, so that the query could be canceled by BE and send the error status + // to FE, then FE could send cancel to other BEs. + return Status::create(_closure->result.status()); } private: