[BUG][PeerTaskInstancePriorityQueue]string formatter

4 years ago · b2a871b4c5
1 changed files with 1 additions and 2 deletions
--- a/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/queue/PeerTaskInstancePriorityQueue.java
+++ b/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/queue/PeerTaskInstancePriorityQueue.java
@ -82,8 +82,7 @@ public class PeerTaskInstancePriorityQueue implements TaskPriorityQueue<TaskInst
     */
    @Override
    public TaskInstance poll(long timeout, TimeUnit unit) throws TaskPriorityQueueException {
-        throw new TaskPriorityQueueException("This operation is not currently supported," +
-            "and suggest to use PriorityBlockingQueue if you want！");
+        throw new TaskPriorityQueueException("This operation is not currently supported and suggest to use PriorityBlockingQueue if you want！");
    }

    /**