This is an automated email from the ASF dual-hosted git repository. kxiao pushed a commit to branch branch-2.0 in repository https://gitbox.apache.org/repos/asf/doris.git
commit 4cd9c20cd8b074a663374617ed9d6255672bc4fa Author: airborne12 <[email protected]> AuthorDate: Sun Jul 9 23:45:28 2023 +0800 [Fix](pipeline) fix ExchangeSinkBuffer request id memory alloc problem (#21647) Co-authored-by: airborne12 <[email protected]> fix ExchangeSinkBuffer request id memory alloc problem --- be/src/pipeline/exec/exchange_sink_buffer.cpp | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/be/src/pipeline/exec/exchange_sink_buffer.cpp b/be/src/pipeline/exec/exchange_sink_buffer.cpp index adddd0999d..e06bb24752 100644 --- a/be/src/pipeline/exec/exchange_sink_buffer.cpp +++ b/be/src/pipeline/exec/exchange_sink_buffer.cpp @@ -58,10 +58,6 @@ ExchangeSinkBuffer::ExchangeSinkBuffer(PUniqueId query_id, PlanNodeId dest_node_ ExchangeSinkBuffer::~ExchangeSinkBuffer() = default; void ExchangeSinkBuffer::close() { - for (const auto& pair : _instance_to_request) { - pair.second->release_finst_id(); - pair.second->release_query_id(); - } _instance_to_broadcast_package_queue.clear(); _instance_to_package_queue.clear(); _instance_to_request.clear(); @@ -269,7 +265,7 @@ Status ExchangeSinkBuffer::_send_rpc(InstanceLoId id) { void ExchangeSinkBuffer::_construct_request(InstanceLoId id, PUniqueId finst_id) { _instance_to_request[id] = std::make_unique<PTransmitDataParams>(); _instance_to_request[id]->mutable_finst_id()->CopyFrom(finst_id); - _instance_to_request[id]->set_allocated_query_id(&_query_id); + _instance_to_request[id]->mutable_query_id()->CopyFrom(_query_id); _instance_to_request[id]->set_node_id(_dest_node_id); _instance_to_request[id]->set_sender_id(_sender_id); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
