f

Author: yiguolei

be/src/runtime/exec_env.h

@@ -114,6 +114,7 @@ class ProcessProfile;
 class HeapProfiler;
 class WalManager;
 class DNSCache;
+class DorisMetrics;
 
 inline bool k_doris_exit = false;
 
@@ -233,6 +234,7 @@ class ExecEnv {
     LoadPathMgr* load_path_mgr() { return _load_path_mgr; }
     BfdParser* bfd_parser() const { return _bfd_parser; }
     BrokerMgr* broker_mgr() const { return _broker_mgr; }
+    DorisMetrics* doris_metrics() { return _doris_metrics; }
     BrpcClientCache<PBackendService_Stub>* brpc_internal_client_cache() const {
         return _internal_client_cache;
     }

be/src/runtime/exec_env_init.cpp

@@ -204,6 +204,9 @@ Status ExecEnv::_init(const std::vector<StorePath>& store_paths,
     if (ready()) {
         return Status::OK();
     }
+    // Doris Metrics is firstly initialized.
+    _doris_metrics = std::make_unique<DorisMetrics>();
+
     std::unordered_map<std::string, std::unique_ptr<vectorized::SpillDataDir>> spill_store_map;
     for (const auto& spill_path : spill_store_paths) {
         spill_store_map.emplace(spill_path.path, std::make_unique<vectorized::SpillDataDir>(
@@ -842,6 +845,7 @@ void ExecEnv::destroy() {
     SAFE_DELETE(_heap_profiler);
 
     _s_tracking_memory = false;
+    _doris_metrics.reset();
 
     LOG(INFO) << "Doris exec envorinment is destoried.";
 }

be/src/util/doris_metrics.h

@@ -248,10 +248,7 @@ class DorisMetrics {
     IntCounter* scanner_task_submit_failed = nullptr;
     IntCounter* scanner_task_running = nullptr;
 
-    static DorisMetrics* instance() {
-        static DorisMetrics instance;
-        return &instance;
-    }
+    static DorisMetrics* instance() { return ExecEnv::GetInstance()->doris_metrics(); }
 
     // not thread-safe, call before calling metrics
     void initialize(