BoYiZhang commented on a change in pull request #4139:
URL:
https://github.com/apache/incubator-dolphinscheduler/pull/4139#discussion_r540062998
##########
File path:
dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/consumer/TaskPriorityQueueConsumer.java
##########
@@ -139,7 +140,13 @@ public void run() {
for (String dispatchFailedTask : failedDispatchTasks) {
taskPriorityQueue.put(dispatchFailedTask);
}
+ // If there are tasks in a cycle that cannot find the worker
group,
+ // sleep for 1 second
+ if (!failedDispatchTasks.isEmpty() &&
taskPriorityQueue.size() <= fetchTaskNum) {
Review comment:
> it is not same.
> the situation that do not need sleep. : failedNumber=1; queueSize=2;
fetchTaskNumber=3
It has been dealt with, but now the main problem is to try many ways. Code
coverage has not been able to
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
