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

fix core of ob_table_load_mem_compactor

Browse Source
This commit is contained in:
coolfishchen
2024-04-23 17:41:28 +00:00
committed by ob-robot
parent 8a11d33bfb
commit 16d0c2d39a
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/observer/table_load/ob_table_load_mem_compactor.cpp
View File

@ -547,8 +547,8 @@ int ObTableLoadMemCompactor::handle_compact_task_finish(int ret_code)
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
if (OB_FAIL(ret_code)) { if (OB_FAIL(ret_code)) {
} else { } else {
const int64_t finish_task_count = ATOMIC_AAF(&finish_task_count_, 1);
int64_t task_to_wait = param_->session_count_ + 1; // one for sample task int64_t task_to_wait = param_->session_count_ + 1; // one for sample task
const int64_t finish_task_count = ATOMIC_AAF(&finish_task_count_, 1);
if (task_to_wait == finish_task_count) { if (task_to_wait == finish_task_count) {
if (OB_LIKELY(!(mem_ctx_.has_error_)) && OB_FAIL(start_finish())) { if (OB_LIKELY(!(mem_ctx_.has_error_)) && OB_FAIL(start_finish())) {
LOG_WARN("fail to start finish", KR(ret)); LOG_WARN("fail to start finish", KR(ret));