This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new ffa4ea66d5c [enhancement](main) donot coredump when be can not start
(#27928)
ffa4ea66d5c is described below
commit ffa4ea66d5c0c130e2bbeb1a9efd9910e50d54c0
Author: Yongqiang YANG <[email protected]>
AuthorDate: Tue Dec 5 20:11:24 2023 +0800
[enhancement](main) donot coredump when be can not start (#27928)
---
be/src/service/doris_main.cpp | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
diff --git a/be/src/service/doris_main.cpp b/be/src/service/doris_main.cpp
index 7da5c74683b..4d276e779de 100644
--- a/be/src/service/doris_main.cpp
+++ b/be/src/service/doris_main.cpp
@@ -398,7 +398,7 @@ int main(int argc, char** argv) {
std::vector<doris::StorePath> paths;
auto olap_res =
doris::parse_conf_store_paths(doris::config::storage_root_path, &paths);
if (!olap_res) {
- LOG(FATAL) << "parse config storage path failed, path=" <<
doris::config::storage_root_path;
+ LOG(ERROR) << "parse config storage path failed, path=" <<
doris::config::storage_root_path;
exit(-1);
}
std::set<std::string> broken_paths;
@@ -411,7 +411,7 @@ int main(int argc, char** argv) {
LOG(WARNING) << "ignore broken disk, path = " << it->path;
it = paths.erase(it);
} else {
- LOG(FATAL) << "a broken disk is found " << it->path;
+ LOG(ERROR) << "a broken disk is found " << it->path;
exit(-1);
}
} else if (!doris::check_datapath_rw(it->path)) {
@@ -419,7 +419,7 @@ int main(int argc, char** argv) {
LOG(WARNING) << "read write test file failed, path=" <<
it->path;
it = paths.erase(it);
} else {
- LOG(FATAL) << "read write test file failed, path=" << it->path;
+ LOG(ERROR) << "read write test file failed, path=" << it->path;
exit(-1);
}
} else {
@@ -428,14 +428,14 @@ int main(int argc, char** argv) {
}
if (paths.empty()) {
- LOG(FATAL) << "All disks are broken, exit.";
+ LOG(ERROR) << "All disks are broken, exit.";
exit(-1);
}
// initialize libcurl here to avoid concurrent initialization
auto curl_ret = curl_global_init(CURL_GLOBAL_ALL);
if (curl_ret != 0) {
- LOG(FATAL) << "fail to initialize libcurl, curl_ret=" << curl_ret;
+ LOG(ERROR) << "fail to initialize libcurl, curl_ret=" << curl_ret;
exit(-1);
}
// add logger for thrift internal
@@ -485,7 +485,7 @@ int main(int argc, char** argv) {
auto exec_env(doris::ExecEnv::GetInstance());
status = doris::ExecEnv::init(doris::ExecEnv::GetInstance(), paths,
broken_paths);
if (status != Status::OK()) {
- LOG(FATAL) << "failed to init doris storage engine, res=" << status;
+ LOG(ERROR) << "failed to init doris storage engine, res=" << status;
exit(-1);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
