(doris) branch branch-3.0 updated: [fix](load) Fix the issue of high-concurrency single-replica load getting stuck #42297 (#42318)

[li...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

liaoxin pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git


The following commit(s) were added to refs/heads/branch-3.0 by this push:
     new 2d98b72621b [fix](load) Fix the issue of high-concurrency single-replica load getting stuck #42297 (#42318)
2d98b72621b is described below

commit 2d98b72621b3aaf0fbb9a467b329ac7cc77e7e35
Author: Xin Liao <li...@126.com>
AuthorDate: Wed Oct 23 23:28:36 2024 +0800

    [fix](load) Fix the issue of high-concurrency single-replica load getting stuck #42297 (#42318)
    
    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 8dc4d7bb3c2..8217bd11bb9 100644
--- a/be/src/service/internal_service.cpp
+++ b/be/src/service/internal_service.cpp
@@ -1966,7 +1966,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([txn_mgr = _engine.txn_manager(), request, response,
+    bool ret = _light_work_pool.try_offer([txn_mgr = _engine.txn_manager(), request, response,
                                            done]() {
         brpc::ClosureGuard closure_guard(done);
         VLOG_CRITICAL << "receive the result of slave replica pull rowset from slave replica. "


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org