diff --git a/be/src/olap/wal/wal_manager.cpp b/be/src/olap/wal/wal_manager.cpp index 0df70919078d75..76795f9f0b69c9 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(_wal_dirs_info->update_all_wal_dir_limit()); static_cast(_wal_dirs_info->update_all_wal_dir_used()); LOG_EVERY_N(INFO, 100) << "Scheduled(every 10s) WAL info: " << get_wal_dirs_info_string();