This is an automated email from the ASF dual-hosted git repository.
wangbo 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 c98d2bf0d3 Fix incorrect priority queue refactor (#21857)
c98d2bf0d3 is described below
commit c98d2bf0d36a72adbfc7ca115dce9781bd42306d
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 c9a73deae0..a68a2ba4a7 100644
--- a/be/src/pipeline/task_queue.cpp
+++ b/be/src/pipeline/task_queue.cpp
@@ -42,7 +42,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]
