From cff1de29ce6587fa5792f04f69544ed973542437 Mon Sep 17 00:00:00 2001 From: meiyi Date: Mon, 11 Dec 2023 17:05:26 +0800 Subject: [PATCH] [fix](group commit) Fix group commit memory calculation (#28242) --- be/src/runtime/group_commit_mgr.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/be/src/runtime/group_commit_mgr.cpp b/be/src/runtime/group_commit_mgr.cpp index 3b3264c5d0..2cc4926661 100644 --- a/be/src/runtime/group_commit_mgr.cpp +++ b/be/src/runtime/group_commit_mgr.cpp @@ -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()) {