Browse Source

[Fix-16764] Tasks dispatched failed weren't delayed properly as documented in GlobalTaskDispatchWaitingQueueLooper

dev
slimtom95 3 weeks ago committed by GitHub
parent
commit
d19655fd1e
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
  1. 2
      dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/GlobalTaskDispatchWaitingQueueLooper.java

2
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/GlobalTaskDispatchWaitingQueueLooper.java

@ -80,7 +80,7 @@ public class GlobalTaskDispatchWaitingQueueLooper extends BaseDaemonThread imple
// If dispatch failed, will put the task back to the queue // If dispatch failed, will put the task back to the queue
// The task will be dispatched after waiting time. // The task will be dispatched after waiting time.
// the waiting time will increase multiple of times, but will not exceed 60 seconds // the waiting time will increase multiple of times, but will not exceed 60 seconds
long waitingTimeMills = Math.max( long waitingTimeMills = Math.min(
taskExecutionRunnable.getTaskExecutionContext().increaseDispatchFailTimes() * 1_000L, 60_000L); taskExecutionRunnable.getTaskExecutionContext().increaseDispatchFailTimes() * 1_000L, 60_000L);
globalTaskDispatchWaitingQueue.dispatchTaskExecuteRunnableWithDelay(taskExecutionRunnable, globalTaskDispatchWaitingQueue.dispatchTaskExecuteRunnableWithDelay(taskExecutionRunnable,
waitingTimeMills); waitingTimeMills);

Loading…
Cancel
Save