GitHub user bmh626 created a discussion: 3.3.0之后的Task超时逻辑问题

我由3.2.2升级到3.3.2版本,任务的超时由StateWheelExecuteThread轮询变更为在任务初始化时将一个TaskTimeoutLifecycleEvent放进DelayQueue,这个Event的delayTime被设置为“System.currentTimeMillis()
 - taskInstance.getSubmitTime().getTime()+ 
TimeUnit.MINUTES.toMillis(timeout)”。我有一个Task数量超过1000的工作流,在3.2.2版本全部执行完毕耗时大约4.5小时,当我升级到3.3.2后,这个工作流中的很多Task会因为worker没有足够的执行线程而一直等待直到超时失败。

GitHub link: https://github.com/apache/dolphinscheduler/discussions/17882

----
This is an automatically sent email for [email protected].
To unsubscribe, please send an email to: 
[email protected]

Reply via email to