database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](group commit) Fix group commit memory calculation (#28242)

Browse Source
This commit is contained in:
meiyi
2023-12-11 17:05:26 +08:00
committed by GitHub
parent ad483efca5
commit cff1de29ce
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
be/src/runtime/group_commit_mgr.cpp
View File

@ -85,7 +85,7 @@ Status LoadBlockQueue::get_block(vectorized::Block* block, bool* find_block, boo
block->swap(*fblock.get());
*find_block = true;
_block_queue.pop_front();
_all_block_queues_bytes->fetch_sub(fblock->bytes(), std::memory_order_relaxed);
_all_block_queues_bytes->fetch_sub(block->bytes(), std::memory_order_relaxed);
_single_block_queue_bytes->fetch_sub(block->bytes(), std::memory_order_relaxed);
}
if (_block_queue.empty() && need_commit && _load_ids.empty()) {