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

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


The following commit(s) were added to refs/heads/branch-2.1 by this push:
     new 3922fdddb61 [cherry-pick](branch-2.1) Pick "[Fix](core) Fix wal mgr 
heap use after free when stop doris (#33131)" (#39545)
3922fdddb61 is described below

commit 3922fdddb614c300fe52105fcedb7ffea966b4bb
Author: abmdocrt <[email protected]>
AuthorDate: Mon Aug 19 22:12:09 2024 +0800

    [cherry-pick](branch-2.1) Pick "[Fix](core) Fix wal mgr heap use after free 
when stop doris (#33131)" (#39545)
    
    Pick #33131
---
 be/src/olap/wal/wal_manager.cpp | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/be/src/olap/wal/wal_manager.cpp b/be/src/olap/wal/wal_manager.cpp
index 0df70919078..76795f9f0b6 100644
--- a/be/src/olap/wal/wal_manager.cpp
+++ b/be/src/olap/wal/wal_manager.cpp
@@ -476,6 +476,11 @@ Status 
WalManager::update_wal_dir_estimated_wal_bytes(const std::string& wal_dir
 
 Status WalManager::_update_wal_dir_info_thread() {
     while (!_stop.load()) {
+        if (!ExecEnv::ready()) {
+            LOG(INFO) << "Sleep 1s to wait for storage engine init.";
+            std::this_thread::sleep_for(std::chrono::milliseconds(1000));
+            continue;
+        }
         static_cast<void>(_wal_dirs_info->update_all_wal_dir_limit());
         static_cast<void>(_wal_dirs_info->update_all_wal_dir_used());
         LOG_EVERY_N(INFO, 100) << "Scheduled(every 10s) WAL info: " << 
get_wal_dirs_info_string();


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to