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

Fix allocator for batch insert

Browse Source
This commit is contained in:
haitaoyang
2024-04-08 13:04:23 +00:00
committed by ob-robot
parent 5bb9dd3417
commit a06dc6b42b
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/storage/access/ob_sstable_row_lock_checker.cpp
View File

@ -66,8 +66,8 @@ int ObSSTableRowLockChecker::init_micro_scanner()
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
if (nullptr == micro_scanner_) { if (nullptr == micro_scanner_) {
if (nullptr == (micro_scanner_ = OB_NEWx(ObMicroBlockRowLockChecker, if (nullptr == (micro_scanner_ = OB_NEWx(ObMicroBlockRowLockChecker,
long_life_allocator_, access_ctx_->stmt_allocator_,
*long_life_allocator_))) { *access_ctx_->stmt_allocator_))) {
ret = OB_ALLOCATE_MEMORY_FAILED; ret = OB_ALLOCATE_MEMORY_FAILED;
LOG_WARN("Fail to allocate memory for micro block row scanner", K(ret)); LOG_WARN("Fail to allocate memory for micro block row scanner", K(ret));
} else if (OB_FAIL(micro_scanner_->init(*iter_param_, *access_ctx_, sstable_))) { } else if (OB_FAIL(micro_scanner_->init(*iter_param_, *access_ctx_, sstable_))) {
@ -213,8 +213,8 @@ int ObSSTableRowLockMultiChecker::init_micro_scanner()
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
if (OB_LIKELY(nullptr == micro_scanner_)) { if (OB_LIKELY(nullptr == micro_scanner_)) {
if (nullptr == (micro_scanner_ = OB_NEWx(ObMicroBlockRowLockMultiChecker, if (nullptr == (micro_scanner_ = OB_NEWx(ObMicroBlockRowLockMultiChecker,
long_life_allocator_, access_ctx_->stmt_allocator_,
*long_life_allocator_))) { *access_ctx_->stmt_allocator_))) {
ret = OB_ALLOCATE_MEMORY_FAILED; ret = OB_ALLOCATE_MEMORY_FAILED;
LOG_WARN("Fail to allocate memory for micro block row scanner", K(ret)); LOG_WARN("Fail to allocate memory for micro block row scanner", K(ret));
} else if (OB_FAIL(micro_scanner_->init(*iter_param_, *access_ctx_, sstable_))) { } else if (OB_FAIL(micro_scanner_->init(*iter_param_, *access_ctx_, sstable_))) {