This is an automated email from the ASF dual-hosted git repository.
panxiaolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new ee9822fa7e [Fix](pipeline) fix ExchangeSinkBuffer request id memory
alloc problem (#21647)
ee9822fa7e is described below
commit ee9822fa7e0dbb7b491b123e067ff5b3c4a7054c
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 0326929e5c..25c9851ca1 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]
