hcq/oceanbase
hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

[CP] Set connect by array block allocator to effective tenant

Browse Source
This commit is contained in:
obdev 2023-09-21 10:44:07 +00:00 committed by ob-robot
parent 9e888053c3
commit c5d85bd5f5
2 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/sql/engine/connect_by/ob_nl_cnnt_by_op.cpp
View File

@ -288,8 +288,10 @@ int ObNLConnectByOp::inner_open()
true /* enable dump */, 0))) {
LOG_WARN("init chunk row store failed", K(ret));
} else {
connect_by_pump_.set_allocator(mem_context_->get_malloc_allocator());
connect_by_pump_.datum_store_.set_allocator(mem_context_->get_malloc_allocator());
ObIAllocator &alloc = mem_context_->get_malloc_allocator();
connect_by_pump_.set_allocator(alloc);
connect_by_pump_.datum_store_.set_allocator(alloc);
connect_by_pump_.pump_stack_.set_block_allocator(ModulePageAllocator(alloc, "CnntArrays"));
}
}
return ret;

6
src/sql/engine/connect_by/ob_nl_cnnt_by_with_index_op.cpp
View File

@ -129,7 +129,11 @@ int ObNLConnectByWithIndexOp::inner_open()
ret = OB_ERR_UNEXPECTED;
LOG_WARN("null memory entity returned", K(ret));
} else {
connect_by_pump_.set_allocator(mem_context_->get_malloc_allocator());
ObIAllocator &alloc = mem_context_->get_malloc_allocator();
connect_by_pump_.set_allocator(alloc);
connect_by_pump_.pump_stack_.set_block_allocator(ModulePageAllocator(alloc, "CnntArrays"));
connect_by_pump_.path_stack_.set_block_allocator(ModulePageAllocator(alloc, "CnntArrays"));
connect_by_pump_.sort_stack_.set_block_allocator(ModulePageAllocator(alloc, "CnntArrays"));
}
}
return ret;