[doris] 26/29: [Fix](storage engine) shutdown cooldown and cold data compaction thread when engine stop (#21639)

[kxiao]

This is an automated email from the ASF dual-hosted git repository.

kxiao pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git

commit fa94f6d3a9b7f583a0cc49924ad9a389a785157d
Author: airborne12 <airborn...@gmail.com>
AuthorDate: Sat Jul 8 22:22:15 2023 +0800

    [Fix](storage engine) shutdown cooldown and cold data compaction thread 
when engine stop (#21639)
    
    when stop be gracefully, storage engine did not shut down cooldown and cold 
data compaction thread correctly.
---
 be/src/olap/storage_engine.cpp | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/be/src/olap/storage_engine.cpp b/be/src/olap/storage_engine.cpp
index 60b0b023c6..bd6f181a76 100644
--- a/be/src/olap/storage_engine.cpp
+++ b/be/src/olap/storage_engine.cpp
@@ -165,6 +165,9 @@ StorageEngine::~StorageEngine() {
     if (_calc_delete_bitmap_thread_pool) {
         _calc_delete_bitmap_thread_pool->shutdown();
     }
+    if (_cold_data_compaction_thread_pool) {
+        _cold_data_compaction_thread_pool->shutdown();
+    }
     _clear();
     _s_instance = nullptr;
 }
@@ -560,6 +563,8 @@ void StorageEngine::stop() {
     THREAD_JOIN(_fd_cache_clean_thread);
     THREAD_JOIN(_tablet_checkpoint_tasks_producer_thread);
     THREAD_JOIN(_async_publish_thread);
+    THREAD_JOIN(_cold_data_compaction_producer_thread);
+    THREAD_JOIN(_cooldown_tasks_producer_thread);
 #undef THREAD_JOIN
 
 #define THREADS_JOIN(threads)            \


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org