yiguolei commented on code in PR #27749:
URL: https://github.com/apache/doris/pull/27749#discussion_r1408997221
##########
be/src/vec/runtime/vdata_stream_recvr.cpp:
##########
@@ -427,11 +427,13 @@ Status VDataStreamRecvr::create_merger(const
VExprContextSPtrs& ordering_expr,
Status VDataStreamRecvr::add_block(const PBlock& pblock, int sender_id, int
be_number,
int64_t packet_seq,
::google::protobuf::Closure** done) {
SCOPED_ATTACH_TASK_WITH_ID(_query_mem_tracker, _query_id,
_fragment_instance_id);
+ _mem_tracker->consume(pblock.ByteSizeLong());
int use_sender_id = _is_merging ? sender_id : 0;
return _sender_queues[use_sender_id]->add_block(pblock, be_number,
packet_seq, done);
}
void VDataStreamRecvr::add_block(Block* block, int sender_id, bool use_move) {
+ _mem_tracker->consume(block->allocated_bytes());
Review Comment:
should also call release memory during remove block from sender queue
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
