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; }