database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[vectorized](join) add try catch in create thread (#15065)

Browse Source
This commit is contained in:
zhangstar333
2022-12-16 19:55:09 +08:00
committed by GitHub
parent ef21eea2e8
commit 874acdf68f
1 changed files with 10 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
be/src/vec/exec/join/vjoin_node_base.cpp
View File

@ -163,11 +163,16 @@ Status VJoinNodeBase::open(RuntimeState* state) {
RETURN_IF_CANCELLED(state);
std::promise<Status> thread_status;
std::thread([this, state, thread_status_p = &thread_status,
parent_span = opentelemetry::trace::Tracer::GetCurrentSpan()] {
OpentelemetryScope scope {parent_span};
this->_probe_side_open_thread(state, thread_status_p);
}).detach();
try {
std::thread([this, state, thread_status_p = &thread_status,
parent_span = opentelemetry::trace::Tracer::GetCurrentSpan()] {
OpentelemetryScope scope {parent_span};
this->_probe_side_open_thread(state, thread_status_p);
}).detach();
} catch (const std::system_error& e) {
LOG(WARNING) << "In VJoinNodeBase::open create thread fail, " << e.what();
return Status::InternalError(e.what());
}
// Open the probe-side child so that it may perform any initialisation in parallel.
// Don't exit even if we see an error, we still need to wait for the build thread