[Bug] [Master] task failed when shell node assign a worker group an then change worker group #11964
Description
Search before asking
- I had searched in the issues and found no similar issues.
What happened
I run a old and simple workflow, but it hung on a node and status shows submit success and hold the status for minutes.
all new task instance hang.
So I have to stop the workflow to let the ds system workfine
server log shows :
[ERROR] 2022-09-15 16:12:29.917 org.apache.dolphinscheduler.server.master.consumer.TaskPriorityQueueConsumer:[144] - ExecuteException dispatch error: fail to execute : Command [type=TASK_EXECUTE_REQUEST, opaque=22407363, bodyLen=1800] due to no suitable worker, current task needs worker group 测试组-master-138 to execute
org.apache.dolphinscheduler.server.master.dispatch.exceptions.ExecuteException: fail to execute : Command [type=TASK_EXECUTE_REQUEST, opaque=22407363, bodyLen=1800] due to no suitable worker, current task needs worker group 测试组-master-138 to execute
at org.apache.dolphinscheduler.server.master.dispatch.ExecutorDispatcher.dispatch(ExecutorDispatcher.java:89)
at org.apache.dolphinscheduler.server.master.consumer.TaskPriorityQueueConsumer.dispatch(TaskPriorityQueueConsumer.java:138)
at org.apache.dolphinscheduler.server.master.consumer.TaskPriorityQueueConsumer.run(TaskPriorityQueueConsumer.java:101)
[ERROR] 2022-09-15 16:12:29.917 org.apache.dolphinscheduler.server.master.consumer.TaskPriorityQueueConsumer:[146] - dispatch error: java.lang.NullPointerException
java.lang.NullPointerException: null
What you expected to happen
It work fine
How to reproduce
made a workflow and asign a worker group on a node
then change the worker group name
then the node hang
Anything else
No response
Version
2.0.5
Are you willing to submit PR?
- Yes I am willing to submit a PR!
Code of Conduct
- I agree to follow this project's Code of Conduct