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="