NED

apache · Dec 27, 2024 · 5e27cf5 · 5e27cf5
1 parent fa458b5
commit 5e27cf5
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/be/src/util/threadpool.cpp b/be/src/util/threadpool.cpp
@@ -272,6 +272,8 @@ ThreadPool::~ThreadPool() {
     // There should only be one live token: the one used in tokenless submission.
     CHECK_EQ(1, _tokens.size()) << strings::Substitute(
             "Threadpool $0 destroyed with $1 allocated tokens", _name, _tokens.size());
+    // FOR DEBU, need remove
+    std::cerr << "Threadpool " << _name << " deconstruct " << std::endl;
     shutdown();
 }
 
@@ -327,6 +329,7 @@ Status ThreadPool::init() {
 }
 
 void ThreadPool::shutdown() {
+    std::cerr << "Threadpool " << _name << " shutdonw. " << std::endl;
     DorisMetrics::instance()->metric_registry()->deregister_entity(_metric_entity);
     debug::ScopedTSANIgnoreReadsAndWrites ignore_tsan;
     std::unique_lock<std::mutex> l(_lock);

diff --git a/regression-test/suites/workload_manager_p0/test_metrics_with_workload_group.groovy b/regression-test/suites/workload_manager_p0/test_metrics_with_workload_group.groovy
@@ -68,5 +68,8 @@ suite("test_metrics_with_workload_group") {
             List<String> lines = filteredMetrics.split('\n').findAll { it.trim() }
             assert lines.size() == 5
         }
+
+        sql "drop workload group if exists test_wg_metrics;"
     }
+    sql "drop workload group if exists test_wg_metrics;"
 }