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

[BUG.FIX] fix -4002 in replay task

Browse Source
This commit is contained in:
Tyshawn
2023-02-09 17:05:38 +00:00
committed by ob-robot
parent 46d0891c42
commit e2d17e767e
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/storage/ob_i_memtable_mgr.cpp
View File

@ -30,9 +30,12 @@ int ObIMemtableMgr::get_active_memtable(ObTableHandleV2 &handle) const
{ {
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
MemMgrRLockGuard lock_guard(lock_); MemMgrRLockGuard lock_guard(lock_);
if (OB_UNLIKELY(memtable_tail_ <= 0)) { if (OB_UNLIKELY(memtable_tail_ < memtable_head_)) {
ret = OB_ERR_UNEXPECTED;
STORAGE_LOG(WARN, "unexpected error, tail < head", K(ret), K(memtable_tail_), K(memtable_head_));
} else if (OB_UNLIKELY(memtable_tail_ == memtable_head_)) {
ret = OB_ENTRY_NOT_EXIST; ret = OB_ENTRY_NOT_EXIST;
STORAGE_LOG(WARN, "There is no memtable in MemtableMgr", K(ret), K(memtable_tail_)); STORAGE_LOG(WARN, "There is no memtable in MemtableMgr", K(ret), K(memtable_head_), K(memtable_tail_));
} else if (OB_FAIL(get_ith_memtable(memtable_tail_ - 1, handle))) { } else if (OB_FAIL(get_ith_memtable(memtable_tail_ - 1, handle))) {
STORAGE_LOG(WARN, "fail to get ith memtable", K(ret), K(memtable_tail_)); STORAGE_LOG(WARN, "fail to get ith memtable", K(ret), K(memtable_tail_));
} else if (OB_UNLIKELY(!handle.is_valid())) { } else if (OB_UNLIKELY(!handle.is_valid())) {