From a9a1bdee79e7ccce7beb56d52721c2dcf7b7202c Mon Sep 17 00:00:00 2001 From: Yukang-Lian Date: Mon, 12 May 2025 20:12:05 +0800 Subject: [PATCH] 1 --- be/src/cloud/cloud_storage_engine.cpp | 2 ++ 1 file changed, 2 insertions(+) diff --git a/be/src/cloud/cloud_storage_engine.cpp b/be/src/cloud/cloud_storage_engine.cpp index cf50eabd03f691..bb9200587dd78e 100644 --- a/be/src/cloud/cloud_storage_engine.cpp +++ b/be/src/cloud/cloud_storage_engine.cpp @@ -686,6 +686,7 @@ Status CloudStorageEngine::_submit_base_compaction_task(const CloudTabletSPtr& t signal::tablet_id = tablet->tablet_id(); Defer defer {[&]() { g_base_compaction_running_task_count << -1; + std::lock_guard lock(_compaction_mtx); _submitted_base_compactions.erase(tablet->tablet_id()); }}; auto st = _request_tablet_global_compaction_lock(ReaderType::READER_BASE_COMPACTION, tablet, @@ -885,6 +886,7 @@ Status CloudStorageEngine::_submit_full_compaction_task(const CloudTabletSPtr& t signal::tablet_id = tablet->tablet_id(); Defer defer {[&]() { g_full_compaction_running_task_count << -1; + std::lock_guard lock(_compaction_mtx); _submitted_full_compactions.erase(tablet->tablet_id()); }}; auto st = _request_tablet_global_compaction_lock(ReaderType::READER_FULL_COMPACTION, tablet,