hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

fix: modify large query sleep time calculate rules

Browse Source
This commit is contained in:
obdev
2023-03-02 15:10:31 +00:00
committed by ob-robot
parent c90bbae954
commit fbb3513d8e
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/observer/omt/ob_tenant.cpp
View File

@ -1445,10 +1445,10 @@ void ObTenant::lq_wait(ObThWorker &w)
{ {
int64_t last_query_us = ObTimeUtility::current_time() - w.get_last_wakeup_ts(); int64_t last_query_us = ObTimeUtility::current_time() - w.get_last_wakeup_ts();
int64_t lq_group_worker_cnt = w.get_group()->get_token_cnt(); int64_t lq_group_worker_cnt = w.get_group()->get_token_cnt();
int64_t unit_min_cpu = unit_min_cpu_; int64_t default_group_worker_cnt = token_cnt_;
double large_query_percentage = GCONF.large_query_worker_percentage / 100.0; double large_query_percentage = GCONF.large_query_worker_percentage / 100.0;
int64_t wait_us = static_cast<int64_t>(last_query_us * lq_group_worker_cnt / int64_t wait_us = static_cast<int64_t>(last_query_us * lq_group_worker_cnt /
(unit_min_cpu * large_query_percentage) - (default_group_worker_cnt * large_query_percentage) -
last_query_us); last_query_us);
wait_us = std::min(wait_us, min(100 * 1000, w.get_timeout_remain())); wait_us = std::min(wait_us, min(100 * 1000, w.get_timeout_remain()));
if (wait_us > 10 * 1000) { if (wait_us > 10 * 1000) {