From ca23020851907242c50639854c93f276bec7bd6b Mon Sep 17 00:00:00 2001 From: obdev Date: Mon, 6 Mar 2023 07:43:47 +0000 Subject: [PATCH] fix table load general table compact concurrency issue --- .../table_load/ob_table_load_general_table_compactor.cpp | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/src/observer/table_load/ob_table_load_general_table_compactor.cpp b/src/observer/table_load/ob_table_load_general_table_compactor.cpp index 7daf811c23..894fdf3825 100644 --- a/src/observer/table_load/ob_table_load_general_table_compactor.cpp +++ b/src/observer/table_load/ob_table_load_general_table_compactor.cpp @@ -424,6 +424,7 @@ int ObTableLoadGeneralTableCompactor::start_compact() int ret = OB_SUCCESS; const int64_t thread_count = store_ctx_->task_scheduler_->get_thread_count(); ObTableLoadTableCtx *ctx = store_ctx_->ctx_; + running_thread_count_ = thread_count; for (int32_t thread_idx = 0; OB_SUCC(ret) && thread_idx < thread_count; ++thread_idx) { ObTableLoadTask *task = nullptr; // 1. 分配task @@ -442,10 +443,6 @@ int ObTableLoadGeneralTableCompactor::start_compact() else if (OB_FAIL(store_ctx_->task_scheduler_->add_task(thread_idx, task))) { LOG_WARN("fail to add task", KR(ret), K(thread_idx), KPC(task)); } - // 5. inc running_thread_count_ - else { - ATOMIC_INC(&running_thread_count_); - } if (OB_FAIL(ret)) { if (nullptr != task) { ctx->free_task(task); -- GitLab