You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Version:v2.0.6
The log shows that we've specified the default resource queue for the job, but it threw an exception: "fail to execute : Command [type=TASK_EXECUTE_REQUEST, opaque=51925416, genCommandTimeMillis=1752110416206, bodyLen=2583] due to no suitable worker, current task needs worker group airflow to execute". Could you help check if this is a worker bug? Our version is v2.0.6. Please let me know if you need more logs.
[ERROR] 2025-07-10 09:20:13.197 org.apache.dolphinscheduler.server.master.consumer.TaskPriorityQueueConsumer:[144] - ExecuteException dispatch error: fail to execute : Command [type=TASK_EXECUTE_REQUEST, opaque=51925402, genCommandTimeMillis=1752110412196, bodyLen=2583] due to no suitable worker, current task needs worker group airflow to execute
org.apache.dolphinscheduler.server.master.dispatch.exceptions.ExecuteException: fail to execute : Command [type=TASK_EXECUTE_REQUEST, opaque=51925402, genCommandTimeMillis=1752110412196, bodyLen=2583] due to no suitable worker, current task needs worker group airflow to execute
at org.apache.dolphinscheduler.server.master.dispatch.ExecutorDispatcher.dispatch(ExecutorDispatcher.java:87)
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] 2025-07-10 09:20:14.198 org.apache.dolphinscheduler.server.master.consumer.TaskPriorityQueueConsumer:[144] - ExecuteException dispatch error: fail to execute : Command [type=TASK_EXECUTE_REQUEST, opaque=51925405, genCommandTimeMillis=1752110413197, bodyLen=2583] due to no suitable worker, current task needs worker group airflow to execute
org.apache.dolphinscheduler.server.master.dispatch.exceptions.ExecuteException: fail to execute : Command [type=TASK_EXECUTE_REQUEST, opaque=51925405, genCommandTimeMillis=1752110413197, bodyLen=2583] due to no suitable worker, current task needs worker group airflow to execute
at org.apache.dolphinscheduler.server.master.dispatch.ExecutorDispatcher.dispatch(ExecutorDispatcher.java:87)
at org.apache.dolphinscheduler.server.master.consumer.TaskPriorityQueueConsumer.dispatch(TaskPriorityQueueConsumer.java:138)
at org.apache.dolphinscheduler.server.master.consumer.TaskPriorityQueueConsumer.run(TaskPriorityQueueConsumer.java:101)
[INFO] 2025-07-10 09:20:14.202 org.apache.dolphinscheduler.server.master.processor.TaskAckProcessor:[71] - taskAckCommand : TaskExecuteAckCommand{taskInstanceId=41774, startTime=Thu Jul 10 09:20:14 CST 2025, host='192.168.170.7:1234', status=1, logPath='/home/dolphinscheduler/dolphinscheduler/logs/10060567211520_15/19392/41774.log', executePath='/tmp/dolphinscheduler/exec/process/7904508147584/10060567211520_15/19392/41774', processInstanceId='19392'}
[INFO] 2025-07-10 09:20:14.202 org.apache.dolphinscheduler.server.master.processor.TaskAckProcessor:[71] - taskAckCommand : TaskExecuteAckCommand{taskInstanceId=41774, startTime=Thu Jul 10 09:20:14 CST 2025, host='192.168.170.7:1234', status=1, logPath='/home/dolphinscheduler/dolphinscheduler/logs/10060567211520_15/19392/41774.log', executePath='/tmp/dolphinscheduler/exec/process/7904508147584/10060567211520_15/19392/41774', processInstanceId='0'}
[INFO] 2025-07-10 09:20:14.386 org.apache.dolphinscheduler.server.master.processor.queue.TaskResponseService:[223] - already exists handler process size:0
[INFO] 2025-07-10 09:20:14.389 org.apache.dolphinscheduler.server.master.processor.queue.TaskResponseService:[230] - persist events 19392 succeeded.
[ERROR] 2025-07-10 09:20:15.202 org.apache.dolphinscheduler.server.master.consumer.TaskPriorityQueueConsumer:[144] - ExecuteException dispatch error: fail to execute : Command [type=TASK_EXECUTE_REQUEST, opaque=51925408, genCommandTimeMillis=1752110414201, bodyLen=2583] due to no suitable worker, current task needs worker group airflow to execute
org.apache.dolphinscheduler.server.master.dispatch.exceptions.ExecuteException: fail to execute : Command [type=TASK_EXECUTE_REQUEST, opaque=51925408, genCommandTimeMillis=1752110414201, bodyLen=2583] due to no suitable worker, current task needs worker group airflow to execute
at org.apache.dolphinscheduler.server.master.dispatch.ExecutorDispatcher.dispatch(ExecutorDispatcher.java:87)
at org.apache.dolphinscheduler.server.master.consumer.TaskPriorityQueueConsumer.dispatch(TaskPriorityQueueConsumer.java:138)
at org.apache.dolphinscheduler.server.master.consumer.TaskPriorityQueueConsumer.run(TaskPriorityQueueConsumer.java:101)
[INFO] 2025-07-10 09:20:15.773 org.apache.dolphinscheduler.server.master.processor.TaskResponseProcessor:[72] - received command : TaskExecuteResponseCommand{taskInstanceId=41774, processInstanceId=19392, status=6, startTime=null, endTime=Thu Jul 10 09:20:15 CST 2025, host=null, logPath=null, executePath=null, processId=61331, appIds='', varPool=[]}
[ERROR] 2025-07-10 09:20:16.204 org.apache.dolphinscheduler.server.master.consumer.TaskPriorityQueueConsumer:[144] - ExecuteException dispatch error: fail to execute : Command [type=TASK_EXECUTE_REQUEST, opaque=51925413, genCommandTimeMillis=1752110415202, bodyLen=2583] due to no suitable worker, current task needs worker group airflow to execute
org.apache.dolphinscheduler.server.master.dispatch.exceptions.ExecuteException: fail to execute : Command [type=TASK_EXECUTE_REQUEST, opaque=51925413, genCommandTimeMillis=1752110415202, bodyLen=2583] due to no suitable worker, current task needs worker group airflow to execute
at org.apache.dolphinscheduler.server.master.dispatch.ExecutorDispatcher.dispatch(ExecutorDispatcher.java:87)
at org.apache.dolphinscheduler.server.master.consumer.TaskPriorityQueueConsumer.dispatch(TaskPriorityQueueConsumer.java:138)
at org.apache.dolphinscheduler.server.master.consumer.TaskPriorityQueueConsumer.run(TaskPriorityQueueConsumer.java:101)
[INFO] 2025-07-10 09:20:16.207 org.apache.dolphinscheduler.server.master.processor.TaskAckProcessor:[71] - taskAckCommand : TaskExecuteAckCommand{taskInstanceId=41775, startTime=Thu Jul 10 09:20:16 CST 2025, host='192.168.170.7:1234', status=1, logPath='/home/dolphinscheduler/dolphinscheduler/logs/10060567211520_15/19392/41775.log', executePath='/tmp/dolphinscheduler/exec/process/7904508147584/10060567211520_15/19392/41775', processInstanceId='0'}
[INFO] 2025-07-10 09:20:16.386 org.apache.dolphinscheduler.server.master.processor.queue.TaskResponseService:[223] - already exists handler process size:0
[INFO] 2025-07-10 09:20:16.391 org.apache.dolphinscheduler.server.master.processor.queue.TaskResponseService:[230] - persist events 19392 succeeded.
[INFO] 2025-07-10 09:20:16.873 org.apache.dolphinscheduler.server.master.runner.EventExecuteService:[127] - handle process instance : 19392 , events count:1
[INFO] 2025-07-10 09:20:16.874 org.apache.dolphinscheduler.server.master.runner.EventExecuteService:[130] - already exists handler process size:0
[INFO] 2025-07-10 09:20:16.874 org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteThread:[308] - process event: State Event :key: null type: TASK_STATE_CHANGE executeStatus: FAILURE task instance id: 41774 process instance id: 19392 context: null
[INFO] 2025-07-10 09:20:16.875 org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteThread:[422] - work flow 19392 task 41774 state:FAILURE
[INFO] 2025-07-10 09:20:16.876 org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteThread:[1412] - kill called on process instance id: 19392, num: 7
[INFO] 2025-07-10 09:20:16.879 org.apache.dolphinscheduler.server.master.runner.task.CommonTaskProcessor:[209] - master kill taskInstance name :bigorder_buy_sh taskInstance id:41769
[INFO] 2025-07-10 09:20:16.880 org.apache.dolphinscheduler.server.master.runner.task.CommonTaskProcessor:[209] - master kill taskInstance name :bigorder_buy_log_sz taskInstance id:41771
[INFO] 2025-07-10 09:20:16.881 org.apache.dolphinscheduler.server.master.runner.task.CommonTaskProcessor:[209] - master kill taskInstance name :bigorder_sell_log_sz taskInstance id:41772
[INFO] 2025-07-10 09:20:16.882 org.apache.dolphinscheduler.server.master.runner.task.CommonTaskProcessor:[209] - master kill taskInstance name :bigorder_buy_sz taskInstance id:41773
[INFO] 2025-07-10 09:20:16.883 org.apache.dolphinscheduler.server.master.runner.task.CommonTaskProcessor:[209] - master kill taskInstance name :bigorder_buy_log_sh taskInstance id:41775
[INFO] 2025-07-10 09:20:16.884 org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteThread:[308] - process event: State Event :key: null type: PROCESS_STATE_CHANGE executeStatus: STOP task instance id: 0 process instance id: 19392 context: null
[INFO] 2025-07-10 09:20:16.884 org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteThread:[492] - process:19392 state RUNNING_EXECUTION change to STOP
[INFO] 2025-07-10 09:20:16.885 org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteThread:[1310] - work flow process instance [id: 19392, name:bigorder测试JAVA-15-20250710092000952], state change from RUNNING_EXECUTION to STOP, cmd type: SCHEDULER
[INFO] 2025-07-10 09:20:16.886 org.apache.dolphinscheduler.server.master.runner.EventExecuteService:[139] - process instance 19392 finished.
[ERROR] 2025-07-10 09:20:17.207 org.apache.dolphinscheduler.server.master.consumer.TaskPriorityQueueConsumer:[144] - ExecuteException dispatch error: fail to execute : Command [type=TASK_EXECUTE_REQUEST, opaque=51925416, genCommandTimeMillis=1752110416206, bodyLen=2583] due to no suitable worker, current task needs worker group airflow to execute
org.apache.dolphinscheduler.server.master.dispatch.exceptions.ExecuteException: fail to execute : Command [type=TASK_EXECUTE_REQUEST, opaque=51925416, genCommandTimeMillis=1752110416206, bodyLen=2583] due to no suitable worker, current task needs worker group airflow to execute
at org.apache.dolphinscheduler.server.master.dispatch.ExecutorDispatcher.dispatch(ExecutorDispatcher.java:87)
at org.apache.dolphinscheduler.server.master.consumer.TaskPriorityQueueConsumer.dispatch(TaskPriorityQueueConsumer.java:138)
at org.apache.dolphinscheduler.server.master.consumer.TaskPriorityQueueConsumer.run(TaskPriorityQueueConsumer.java:101)
[INFO] 2025-07-10 09:20:17.387 org.apache.dolphinscheduler.server.master.processor.queue.TaskResponseService:[223] - already exists handler process size:0
[INFO] 2025-07-10 09:20:17.389 org.apache.dolphinscheduler.server.master.processor.queue.TaskResponseService:[230] - persist events 19392 succeeded.
[INFO] 2025-07-10 09:20:17.390 org.apache.dolphinscheduler.server.master.processor.queue.TaskResponseService:[233] - remove process instance: 19392
[ERROR] 2025-07-10 09:20:18.208 org.apache.dolphinscheduler.server.master.consumer.TaskPriorityQueueConsumer:[144] - ExecuteException dispatch error: fail to execute : Command [type=TASK_EXECUTE_REQUEST, opaque=51925426, genCommandTimeMillis=1752110417207, bodyLen=2583] due to no suitable worker, current task needs worker group airflow to execute
org.apache.dolphinscheduler.server.master.dispatch.exceptions.ExecuteException: fail to execute : Command [type=TASK_EXECUTE_REQUEST, opaque=51925426, genCommandTimeMillis=1752110417207, bodyLen=2583] due to no suitable worker, current task needs worker group airflow to execute
at org.apache.dolphinscheduler.server.master.dispatch.ExecutorDispatcher.dispatch(ExecutorDispatcher.java:87)
at org.apache.dolphinscheduler.server.master.consumer.TaskPriorityQueueConsumer.dispatch(TaskPriorityQueueConsumer.java:138)
at org.apache.dolphinscheduler.server.master.consumer.TaskPriorityQueueConsumer.run(TaskPriorityQueueConsumer.java:101)
[INFO] 2025-07-10 09:20:15.773 org.apache.dolphinscheduler.server.master.processor.TaskResponseProcessor:[72] - received command : TaskExecuteResponseCommand{taskInstanceId=41774, processInstanceId=19392, status=6, startTime=null, endTime=Thu Jul 10 09:20:15 CST 2025, host=null, logPath=null, executePath=null, processId=61331, appIds='', varPool=[]}
[ERROR] 2025-07-10 09:20:16.204 org.apache.dolphinscheduler.server.master.consumer.TaskPriorityQueueConsumer:[144] - ExecuteException dispatch error: fail to execute : Command [type=TASK_EXECUTE_REQUEST, opaque=51925413, genCommandTimeMillis=1752110415202, bodyLen=2583] due to no suitable worker, current task needs worker group airflow to execute
org.apache.dolphinscheduler.server.master.dispatch.exceptions.ExecuteException: fail to execute : Command [type=TASK_EXECUTE_REQUEST, opaque=51925413, genCommandTimeMillis=1752110415202, bodyLen=2583] due to no suitable worker, current task needs worker group airflow to execute
at org.apache.dolphinscheduler.server.master.dispatch.ExecutorDispatcher.dispatch(ExecutorDispatcher.java:87)
at org.apache.dolphinscheduler.server.master.consumer.TaskPriorityQueueConsumer.dispatch(TaskPriorityQueueConsumer.java:138)
at org.apache.dolphinscheduler.server.master.consumer.TaskPriorityQueueConsumer.run(TaskPriorityQueueConsumer.java:101)
[INFO] 2025-07-10 09:20:16.207 org.apache.dolphinscheduler.server.master.processor.TaskAckProcessor:[71] - taskAckCommand : TaskExecuteAckCommand{taskInstanceId=41775, startTime=Thu Jul 10 09:20:16 CST 2025, host='192.168.170.7:1234', status=1, logPath='/home/dolphinscheduler/dolphinscheduler/logs/10060567211520_15/19392/41775.log', executePath='/tmp/dolphinscheduler/exec/process/7904508147584/10060567211520_15/19392/41775', processInstanceId='0'}
[INFO] 2025-07-10 09:20:16.207 org.apache.dolphinscheduler.server.master.processor.TaskAckProcessor:[71] - taskAckCommand : TaskExecuteAckCommand{taskInstanceId=41775, startTime=Thu Jul 10 09:20:16 CST 2025, host='192.168.170.7:1234', status=1, logPath='/home/dolphinscheduler/dolphinscheduler/logs/10060567211520_15/19392/41775.log', executePath='/tmp/dolphinscheduler/exec/process/7904508147584/10060567211520_15/19392/41775', processInstanceId='19392'}
[INFO] 2025-07-10 09:20:16.386 org.apache.dolphinscheduler.server.master.processor.queue.TaskResponseService:[223] - already exists handler process size:0
[INFO] 2025-07-10 09:20:16.391 org.apache.dolphinscheduler.server.master.processor.queue.TaskResponseService:[230] - persist events 19392 succeeded.
[INFO] 2025-07-10 09:20:16.873 org.apache.dolphinscheduler.server.master.runner.EventExecuteService:[127] - handle process instance : 19392 , events count:1
[INFO] 2025-07-10 09:20:16.874 org.apache.dolphinscheduler.server.master.runner.EventExecuteService:[130] - already exists handler process size:0
[INFO] 2025-07-10 09:20:16.874 org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteThread:[308] - process event: State Event :key: null type: TASK_STATE_CHANGE executeStatus: FAILURE task instance id: 41774 process instance id: 19392 context: null
[INFO] 2025-07-10 09:20:16.875 org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteThread:[422] - work flow 19392 task 41774 state:FAILURE
[INFO] 2025-07-10 09:20:16.876 org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteThread:[1412] - kill called on process instance id: 19392, num: 7
[INFO] 2025-07-10 09:20:16.879 org.apache.dolphinscheduler.server.master.runner.task.CommonTaskProcessor:[209] - master kill taskInstance name :bigorder_buy_sh taskInstance id:41769
[INFO] 2025-07-10 09:20:16.880 org.apache.dolphinscheduler.server.master.runner.task.CommonTaskProcessor:[209] - master kill taskInstance name :bigorder_buy_log_sz taskInstance id:41771
[INFO] 2025-07-10 09:20:16.881 org.apache.dolphinscheduler.server.master.runner.task.CommonTaskProcessor:[209] - master kill taskInstance name :bigorder_sell_log_sz taskInstance id:41772
[INFO] 2025-07-10 09:20:16.882 org.apache.dolphinscheduler.server.master.runner.task.CommonTaskProcessor:[209] - master kill taskInstance name :bigorder_buy_sz taskInstance id:41773
[INFO] 2025-07-10 09:20:16.883 org.apache.dolphinscheduler.server.master.runner.task.CommonTaskProcessor:[209] - master kill taskInstance name :bigorder_buy_log_sh taskInstance id:41775
reacted with thumbs up emoji reacted with thumbs down emoji reacted with laugh emoji reacted with hooray emoji reacted with confused emoji reacted with heart emoji reacted with rocket emoji reacted with eyes emoji
Uh oh!
There was an error while loading. Please reload this page.
-
Version:
v2.0.6
The log shows that we've specified the default resource queue for the job, but it threw an exception:
"fail to execute : Command [type=TASK_EXECUTE_REQUEST, opaque=51925416, genCommandTimeMillis=1752110416206, bodyLen=2583] due to no suitable worker, current task needs worker group airflow to execute".
Could you help check if this is a worker bug? Our version is v2.0.6. Please let me know if you need more logs.Beta Was this translation helpful? Give feedback.
All reactions