From a06dc6b42b844dc5a5bf3613d5bae2d883f80914 Mon Sep 17 00:00:00 2001 From: haitaoyang Date: Mon, 8 Apr 2024 13:04:23 +0000 Subject: [PATCH] Fix allocator for batch insert --- src/storage/access/ob_sstable_row_lock_checker.cpp | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/storage/access/ob_sstable_row_lock_checker.cpp b/src/storage/access/ob_sstable_row_lock_checker.cpp index e7e3dd8ec..cb1712c62 100644 --- a/src/storage/access/ob_sstable_row_lock_checker.cpp +++ b/src/storage/access/ob_sstable_row_lock_checker.cpp @@ -66,8 +66,8 @@ int ObSSTableRowLockChecker::init_micro_scanner() int ret = OB_SUCCESS; if (nullptr == micro_scanner_) { if (nullptr == (micro_scanner_ = OB_NEWx(ObMicroBlockRowLockChecker, - long_life_allocator_, - *long_life_allocator_))) { + access_ctx_->stmt_allocator_, + *access_ctx_->stmt_allocator_))) { ret = OB_ALLOCATE_MEMORY_FAILED; 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_))) { @@ -213,8 +213,8 @@ int ObSSTableRowLockMultiChecker::init_micro_scanner() int ret = OB_SUCCESS; if (OB_LIKELY(nullptr == micro_scanner_)) { if (nullptr == (micro_scanner_ = OB_NEWx(ObMicroBlockRowLockMultiChecker, - long_life_allocator_, - *long_life_allocator_))) { + access_ctx_->stmt_allocator_, + *access_ctx_->stmt_allocator_))) { ret = OB_ALLOCATE_MEMORY_FAILED; 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_))) {