Fix incorrect priority queue refactor (#21857)

2023-07-17 14:56:24 +08:00
parent 5fc0a84735
commit c98d2bf0d3
1 changed files with 1 additions and 1 deletions
--- 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;
    }