This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new 47c3f05206d branch-3.0: [cleanup](load) remove bvar
"g_memtable_input_block_allocated_size" #44304 (#44643)
47c3f05206d is described below
commit 47c3f05206d26772302e28227698ca6d8bc7138d
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Wed Nov 27 10:20:10 2024 +0800
branch-3.0: [cleanup](load) remove bvar
"g_memtable_input_block_allocated_size" #44304 (#44643)
Cherry-picked from #44304
Co-authored-by: Kaijie Chen <[email protected]>
---
be/src/olap/memtable.cpp | 6 ------
1 file changed, 6 deletions(-)
diff --git a/be/src/olap/memtable.cpp b/be/src/olap/memtable.cpp
index a70486e39b3..69c886d76ef 100644
--- a/be/src/olap/memtable.cpp
+++ b/be/src/olap/memtable.cpp
@@ -44,7 +44,6 @@
namespace doris {
bvar::Adder<int64_t> g_memtable_cnt("memtable_cnt");
-bvar::Adder<int64_t>
g_memtable_input_block_allocated_size("memtable_input_block_allocated_size");
using namespace ErrorCode;
@@ -146,7 +145,6 @@ MemTable::~MemTable() {
<< _mem_tracker->consumption();
}
}
- g_memtable_input_block_allocated_size <<
-_input_mutable_block.allocated_bytes();
g_memtable_cnt << -1;
if (_keys_type != KeysType::DUP_KEYS) {
for (auto it = _row_in_blocks.begin(); it != _row_in_blocks.end();
it++) {
@@ -208,11 +206,8 @@ Status MemTable::insert(const vectorized::Block*
input_block,
auto num_rows = row_idxs.size();
size_t cursor_in_mutableblock = _input_mutable_block.rows();
- auto block_size0 = _input_mutable_block.allocated_bytes();
RETURN_IF_ERROR(_input_mutable_block.add_rows(input_block, row_idxs.data(),
row_idxs.data() + num_rows,
&_column_offset));
- auto block_size1 = _input_mutable_block.allocated_bytes();
- g_memtable_input_block_allocated_size << block_size1 - block_size0;
for (int i = 0; i < num_rows; i++) {
_row_in_blocks.emplace_back(new RowInBlock {cursor_in_mutableblock +
i});
}
@@ -522,7 +517,6 @@ Status
MemTable::_to_block(std::unique_ptr<vectorized::Block>* res) {
}
RETURN_IF_ERROR(_sort_by_cluster_keys());
}
- g_memtable_input_block_allocated_size <<
-_input_mutable_block.allocated_bytes();
_input_mutable_block.clear();
// After to block, all data in arena is saved in the block
_arena.reset();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
