From 26f2aadb060f80f825785251be601310ff878da2 Mon Sep 17 00:00:00 2001
From: sleo <97011595+alei1206@users.noreply.github.com>
Date: Fri, 24 May 2024 20:09:10 +0800
Subject: [PATCH] Rename variable QUEUE_MAX_SIZE to QUEUE_INITIAL_SIZE (#16040)

---
 .../service/queue/StandByTaskInstancePriorityQueue.java   | 8 +-------
 1 file changed, 1 insertion(+), 7 deletions(-)

diff --git a/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/queue/StandByTaskInstancePriorityQueue.java b/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/queue/StandByTaskInstancePriorityQueue.java
index c11c4fe5a9..d02c5715e3 100644
--- a/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/queue/StandByTaskInstancePriorityQueue.java
+++ b/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/queue/StandByTaskInstancePriorityQueue.java
@@ -36,16 +36,10 @@ import com.google.common.base.Preconditions;
  */
 public class StandByTaskInstancePriorityQueue implements TaskPriorityQueue<TaskInstance> {
 
-    /**
-     * queue size
-     */
-    private static final Integer QUEUE_MAX_SIZE = 3000;
-
     /**
      * queue
      */
-    private final PriorityQueue<TaskInstance> queue =
-            new PriorityQueue<>(QUEUE_MAX_SIZE, new TaskInstancePriorityComparator());
+    private final PriorityQueue<TaskInstance> queue = new PriorityQueue<>(new TaskInstancePriorityComparator());
     private final Set<String> taskInstanceIdentifySet = Collections.synchronizedSet(new HashSet<>());
 
     /**