This is an automated email from the ASF dual-hosted git repository.
wenjun pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
The following commit(s) were added to refs/heads/dev by this push:
new 26f2aadb06 Rename variable QUEUE_MAX_SIZE to QUEUE_INITIAL_SIZE
(#16040)
26f2aadb06 is described below
commit 26f2aadb060f80f825785251be601310ff878da2
Author: sleo <[email protected]>
AuthorDate: Fri May 24 20:09:10 2024 +0800
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<>());
/**
