From 86fa6a37c756e01c19c3569059e4dc17a15e8cd3 Mon Sep 17 00:00:00 2001 From: Xin Liao Date: Wed, 23 Oct 2024 23:28:05 +0800 Subject: [PATCH] [fix](load) Fix the issue of high-concurrency single-replica load getting stuck #42297 (#42317) cherry pick from #42297 --- be/src/service/internal_service.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/be/src/service/internal_service.cpp b/be/src/service/internal_service.cpp index 316c44d1ed..bcadbfd90e 100644 --- a/be/src/service/internal_service.cpp +++ b/be/src/service/internal_service.cpp @@ -1977,7 +1977,7 @@ void PInternalServiceImpl::_response_pull_slave_rowset(const std::string& remote void PInternalServiceImpl::response_slave_tablet_pull_rowset( google::protobuf::RpcController* controller, const PTabletWriteSlaveDoneRequest* request, PTabletWriteSlaveDoneResult* response, google::protobuf::Closure* done) { - bool ret = _heavy_work_pool.try_offer([request, response, done]() { + bool ret = _light_work_pool.try_offer([request, response, done]() { brpc::ClosureGuard closure_guard(done); VLOG_CRITICAL << "receive the result of slave replica pull rowset from slave replica. " "slave server="