From 16d0c2d39a77ffbb48147f22a031a24b84583a90 Mon Sep 17 00:00:00 2001 From: coolfishchen Date: Tue, 23 Apr 2024 17:41:28 +0000 Subject: [PATCH] fix core of ob_table_load_mem_compactor --- src/observer/table_load/ob_table_load_mem_compactor.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/observer/table_load/ob_table_load_mem_compactor.cpp b/src/observer/table_load/ob_table_load_mem_compactor.cpp index a07365592..0c756824c 100644 --- a/src/observer/table_load/ob_table_load_mem_compactor.cpp +++ b/src/observer/table_load/ob_table_load_mem_compactor.cpp @@ -547,8 +547,8 @@ int ObTableLoadMemCompactor::handle_compact_task_finish(int ret_code) int ret = OB_SUCCESS; if (OB_FAIL(ret_code)) { } 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 + const int64_t finish_task_count = ATOMIC_AAF(&finish_task_count_, 1); if (task_to_wait == finish_task_count) { if (OB_LIKELY(!(mem_ctx_.has_error_)) && OB_FAIL(start_finish())) { LOG_WARN("fail to start finish", KR(ret)); -- GitLab