[fix][mem tracker] Fix MemTracker null pointer in vectorized (#8925)

Fix ThreadMemTrackerMgr::update_tracker null pointer and some details.

Issue Number: close #8920
This commit is contained in:
Xinyi Zou
2022-04-12 10:17:10 +08:00
committed by GitHub
parent f992247779
commit 66d2f4e1fd
8 changed files with 21 additions and 9 deletions

View File

@ -212,6 +212,7 @@ Status ExchangeNode::get_next_merging(RuntimeState* state, RowBatch* output_batc
RETURN_IF_CANCELLED(state);
RETURN_IF_ERROR(state->check_query_state("Exchange, while merging next."));
ADD_THREAD_LOCAL_MEM_TRACKER(_stream_recvr->mem_tracker());
RETURN_IF_ERROR(_stream_recvr->get_next(output_batch, eos));
while ((_num_rows_skipped < _offset)) {
_num_rows_skipped += output_batch->num_rows();