test/DolphinScheduler
1
0
Fork 0
mirror of https://gitee.com/dolphinscheduler/DolphinScheduler.git synced 2024-12-02 12:17:43 +08:00
Code Issues Actions 10 Packages Projects Releases Wiki Activity

Fix worker overload will casue task failed (#16223)

Browse Source 
(cherry picked from commit 4a41e4290ec25bf1165ebc4f043baffb13729a72)
This commit is contained in:
Wenjun Ruan 2024-06-27 08:25:42 +08:00 committed by GitHub
parent 66b7d1274a
commit f13f070242
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/runner/BaseTaskDispatcher.java
View File

@ -55,10 +55,11 @@ public abstract class BaseTaskDispatcher implements TaskDispatcher {
taskInstanceDispatchHost = getTaskInstanceDispatchHost(taskExecuteRunnable) taskInstanceDispatchHost = getTaskInstanceDispatchHost(taskExecuteRunnable)
.orElseThrow(() -> new TaskDispatchException("Cannot find the host to execute task.")); .orElseThrow(() -> new TaskDispatchException("Cannot find the host to execute task."));
} catch (WorkerGroupNotFoundException workerGroupNotFoundException) { } catch (WorkerGroupNotFoundException workerGroupNotFoundException) {
log.error("Dispatch task: {} failed, worker group not found.", // todo: this is a temporary solution, we should refactor the ServerNodeManager to make sure there won't
taskExecuteRunnable.getTaskExecutionContext().getTaskName(), workerGroupNotFoundException); // throw WorkerGroupNotFoundException unless the worker group is not exist in database
addDispatchFailedEvent(taskExecuteRunnable); throw new TaskDispatchException(
return; "Dispatch task: " + taskExecuteRunnable.getTaskExecutionContext().getTaskName() + " failed",
workerGroupNotFoundException);
} }
taskExecuteRunnable.getTaskExecutionContext().setHost(taskInstanceDispatchHost.getAddress()); taskExecuteRunnable.getTaskExecutionContext().setHost(taskInstanceDispatchHost.getAddress());
doDispatch(taskExecuteRunnable); doDispatch(taskExecuteRunnable);