You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by te...@apache.org on 2021/07/30 01:56:25 UTC

[dolphinscheduler] branch dev updated: correct the wrong annotion from zk queue implemented to java priority blocking queue (#5906)

This is an automated email from the ASF dual-hosted git repository.

technoboy 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 efad0ed  correct the wrong annotion from zk queue implemented to java priority blocking queue (#5906)
efad0ed is described below

commit efad0ed2ba1ab2b1f9736a1a89426201c9378646
Author: Yao WANG <Ya...@gmail.com>
AuthorDate: Fri Jul 30 09:56:21 2021 +0800

    correct the wrong annotion from zk queue implemented to java priority blocking queue (#5906)
    
    Co-authored-by: ywang46 <yw...@paypal.com>
---
 .../apache/dolphinscheduler/service/queue/TaskPriorityQueueImpl.java   | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/queue/TaskPriorityQueueImpl.java b/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/queue/TaskPriorityQueueImpl.java
index 8775a27..8d630be 100644
--- a/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/queue/TaskPriorityQueueImpl.java
+++ b/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/queue/TaskPriorityQueueImpl.java
@@ -25,8 +25,7 @@ import java.util.concurrent.TimeUnit;
 import org.springframework.stereotype.Service;
 
 /**
- * A singleton of a task queue implemented with zookeeper
- * tasks queue implementation
+ * A singleton of a task queue implemented using PriorityBlockingQueue
  */
 @Service
 public class TaskPriorityQueueImpl implements TaskPriorityQueue<TaskPriority> {