This is an automated email from the ASF dual-hosted git repository.
jianliangqi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 76fd566403f [Improve](topn opt) change `multiget_data` RPC worker pool
from `_heavy_work_pool` to `_light_work_pool` (#25741)
76fd566403f is described below
commit 76fd566403ff21cc90b111049386967d9e327f01
Author: lihangyu <[email protected]>
AuthorDate: Tue Oct 24 14:07:52 2023 +0800
[Improve](topn opt) change `multiget_data` RPC worker pool from
`_heavy_work_pool` to `_light_work_pool` (#25741)
Under some workload the `multiget_data` maybe stuck and raise rpc timeout.
Inorder to to minimize the latency of point queries, so it should be placed
in `_light_work_pool`, since
it's typically finished in hundreds of millisecond
---
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 37a0b076d95..d7f72885283 100644
--- a/be/src/service/internal_service.cpp
+++ b/be/src/service/internal_service.cpp
@@ -1733,7 +1733,7 @@ void
PInternalServiceImpl::multiget_data(google::protobuf::RpcController* contro
const PMultiGetRequest* request,
PMultiGetResponse* response,
google::protobuf::Closure* done) {
- bool ret = _heavy_work_pool.try_offer([request, response, done, this]() {
+ bool ret = _light_work_pool.try_offer([request, response, done, this]() {
// multi get data by rowid
MonotonicStopWatch watch;
watch.start();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
