This is an automated email from the ASF dual-hosted git repository. kxiao pushed a commit to branch branch-2.0 in repository https://gitbox.apache.org/repos/asf/doris.git
commit 9afdc0218616eb49dda053300dc7cf75c5e9d163 Author: wangbo <[email protected]> AuthorDate: Mon Jul 17 14:56:24 2023 +0800 Fix incorrect priority queue refactor (#21857) --- be/src/pipeline/task_queue.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/be/src/pipeline/task_queue.cpp b/be/src/pipeline/task_queue.cpp index 2c09ac8edd..715c9601cd 100644 --- a/be/src/pipeline/task_queue.cpp +++ b/be/src/pipeline/task_queue.cpp @@ -43,7 +43,7 @@ PipelineTask* SubTaskQueue::try_take(bool is_steal) { PriorityTaskQueue::PriorityTaskQueue() : _closed(false) { double factor = 1; - for (int i = 0; i < SUB_QUEUE_LEVEL; ++i) { + for (int i = SUB_QUEUE_LEVEL - 1; i >= 0; i--) { _sub_queues[i].set_level_factor(factor); factor *= LEVEL_QUEUE_TIME_FACTOR; } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
