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

branch-2.1: [fix](arrow-flight-sql) Fix fetch_arrow_flight_schema thread pool (#49291)

Browse Source
This commit is contained in:
Xinyi Zou
2025-03-20 17:07:37 +08:00
committed by GitHub
parent df26c6fc51
commit 3f9e989d05
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
be/src/service/internal_service.cpp
View File

@ -917,7 +917,7 @@ void PInternalServiceImpl::fetch_arrow_flight_schema(google::protobuf::RpcContro
const PFetchArrowFlightSchemaRequest* request,
PFetchArrowFlightSchemaResult* result,
google::protobuf::Closure* done) {
bool ret = _light_work_pool.try_offer([request, result, done]() {
bool ret = _arrow_flight_work_pool.try_offer([request, result, done]() {
brpc::ClosureGuard closure_guard(done);
std::shared_ptr<arrow::Schema> schema;
auto st = ExecEnv::GetInstance()->result_mgr()->find_arrow_schema(
@ -942,7 +942,7 @@ void PInternalServiceImpl::fetch_arrow_flight_schema(google::protobuf::RpcContro
st.to_protobuf(result->mutable_status());
});
if (!ret) {
offer_failed(result, done, _heavy_work_pool);
offer_failed(result, done, _arrow_flight_work_pool);
return;
}
}