From c98d2bf0d36a72adbfc7ca115dce9781bd42306d Mon Sep 17 00:00:00 2001
From: wangbo <wangbo@apache.org>
Date: Mon, 17 Jul 2023 14:56:24 +0800
Subject: [PATCH] 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;
     }