njnu-seafish commented on PR #17821:
URL:
https://github.com/apache/dolphinscheduler/pull/17821#issuecomment-3690753193
The second version of the code has been verified to work in our actual test
environment. The specific logs are as follows:
> [WI-193][TI-0] - 2025-12-25 09:58:53.578 INFO
[ds-workflow-eventbus-worker-5] o.a.d.s.m.e.WorkflowEventBus:[41] - Publish
event: TaskStartLifecycleEvent{task=sh01}
[WI-193][TI-0] - 2025-12-25 09:58:53.578 INFO
[ds-workflow-eventbus-worker-5]
o.a.d.s.m.e.w.l.h.AbstractWorkflowLifecycleEventHandler:[52] - Fired workflow
flow_condition_import_no_environment-20251225095821727
LifecycleEvent[WorkflowTopologyLogicalTransitionWithTaskFinishLifecycleEvent{task=sh001taskState=SUCCESS}]
with state: RUNNING_EXECUTION
[WI-193][TI-0] - 2025-12-25 09:58:53.583 INFO
[ds-workflow-eventbus-worker-5] o.a.d.s.m.e.WorkflowEventBus:[41] - Publish
event: TaskDispatchLifecycleEvent{task=sh01}
[WI-193][TI-0] - 2025-12-25 09:58:53.583 INFO
[ds-workflow-eventbus-worker-5]
o.a.d.s.m.e.t.l.h.AbstractTaskLifecycleEventHandler:[47] - Fired task sh01
TaskStartLifecycleEvent{task=sh01} with state SUBMITTED_SUCCESS
[WI-193][TI-0] - 2025-12-25 09:58:53.585 ERROR
[ds-workflow-eventbus-worker-5] o.a.d.s.m.e.t.s.TaskSubmittedStateAction:[117]
- Failed to initialize task execution context, taskName: sh01
java.lang.IllegalArgumentException: Cannot find the environment:
144873539254368
at
org.apache.dolphinscheduler.server.master.runner.TaskExecutionContextFactory.getEnvironmentConfigFromDB(TaskExecutionContextFactory.java:217)
at
org.apache.dolphinscheduler.server.master.runner.TaskExecutionContextFactory.createTaskExecutionContext(TaskExecutionContextFactory.java:102)
at
org.apache.dolphinscheduler.server.master.engine.task.runnable.TaskExecutionRunnable.initializeTaskExecutionContext(TaskExecutionRunnable.java:148)
at
org.apache.dolphinscheduler.server.master.engine.task.statemachine.TaskSubmittedStateAction.onDispatchEvent(TaskSubmittedStateAction.java:115)
at
org.apache.dolphinscheduler.server.master.engine.task.lifecycle.handler.TaskDispatchLifecycleEventHandler.handle(TaskDispatchLifecycleEventHandler.java:40)
at
org.apache.dolphinscheduler.server.master.engine.task.lifecycle.handler.TaskDispatchLifecycleEventHandler.handle(TaskDispatchLifecycleEventHandler.java:31)
at
org.apache.dolphinscheduler.server.master.engine.task.lifecycle.handler.AbstractTaskLifecycleEventHandler.handle(AbstractTaskLifecycleEventHandler.java:46)
at
org.apache.dolphinscheduler.server.master.engine.task.lifecycle.handler.AbstractTaskLifecycleEventHandler.handle(AbstractTaskLifecycleEventHandler.java:32)
at
org.apache.dolphinscheduler.server.master.engine.WorkflowEventBusFireWorker.doFireSingleEvent(WorkflowEventBusFireWorker.java:158)
at
org.apache.dolphinscheduler.server.master.engine.WorkflowEventBusFireWorker.doFireSingleWorkflowEventBus(WorkflowEventBusFireWorker.java:125)
at
org.apache.dolphinscheduler.server.master.engine.WorkflowEventBusFireWorker.fireAllRegisteredEvent(WorkflowEventBusFireWorker.java:89)
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:750)
[WI-193][TI-0] - 2025-12-25 09:58:53.587 INFO
[ds-workflow-eventbus-worker-5] o.a.d.s.m.e.WorkflowEventBus:[41] - Publish
event: TaskFatalLifecycleEvent{task=sh01, endTime=Thu Dec 25 09:58:53 GMT+08:00
2025}
[WI-193][TI-0] - 2025-12-25 09:58:53.587 ERROR
[ds-workflow-eventbus-worker-5] o.a.d.s.m.e.WorkflowEventBusFireWorker:[91] -
Fire event failed for WorkflowExecuteRunnable:
flow_condition_import_no_environment-20251225095821727
org.apache.dolphinscheduler.server.master.engine.exceptions.WorkflowEventFireException:
Failed to fire event: TaskDispatchLifecycleEvent{task=sh01}
at
org.apache.dolphinscheduler.server.master.engine.WorkflowEventBusFireWorker.doFireSingleWorkflowEventBus(WorkflowEventBusFireWorker.java:147)
at
org.apache.dolphinscheduler.server.master.engine.WorkflowEventBusFireWorker.fireAllRegisteredEvent(WorkflowEventBusFireWorker.java:89)
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:750)
Caused by:
org.apache.dolphinscheduler.server.master.exception.TaskExecutionContextCreateException:
Cannot find the environment: 144873539254368
at
org.apache.dolphinscheduler.server.master.engine.task.statemachine.TaskSubmittedStateAction.onDispatchEvent(TaskSubmittedStateAction.java:118)
at
org.apache.dolphinscheduler.server.master.engine.task.lifecycle.handler.TaskDispatchLifecycleEventHandler.handle(TaskDispatchLifecycleEventHandler.java:40)
at
org.apache.dolphinscheduler.server.master.engine.task.lifecycle.handler.TaskDispatchLifecycleEventHandler.handle(TaskDispatchLifecycleEventHandler.java:31)
at
org.apache.dolphinscheduler.server.master.engine.task.lifecycle.handler.AbstractTaskLifecycleEventHandler.handle(AbstractTaskLifecycleEventHandler.java:46)
at
org.apache.dolphinscheduler.server.master.engine.task.lifecycle.handler.AbstractTaskLifecycleEventHandler.handle(AbstractTaskLifecycleEventHandler.java:32)
at
org.apache.dolphinscheduler.server.master.engine.WorkflowEventBusFireWorker.doFireSingleEvent(WorkflowEventBusFireWorker.java:158)
at
org.apache.dolphinscheduler.server.master.engine.WorkflowEventBusFireWorker.doFireSingleWorkflowEventBus(WorkflowEventBusFireWorker.java:125)
... 8 common frames omitted
[WI-193][TI-0] - 2025-12-25 09:58:53.694 INFO
[ds-workflow-eventbus-worker-10] o.a.d.s.m.e.WorkflowEventBus:[41] - Publish
event:
WorkflowTopologyLogicalTransitionWithTaskFinishLifecycleEvent{task=sh01taskState=FAILURE}
[WI-193][TI-0] - 2025-12-25 09:58:53.694 INFO
[ds-workflow-eventbus-worker-10]
o.a.d.s.m.e.t.l.h.AbstractTaskLifecycleEventHandler:[47] - Fired task sh01
TaskFatalLifecycleEvent{task=sh01, endTime=Thu Dec 25 09:58:53 GMT+08:00 2025}
with state SUBMITTED_SUCCESS
[WI-193][TI-0] - 2025-12-25 09:58:53.694 INFO
[ds-workflow-eventbus-worker-10]
o.a.d.s.m.e.w.l.h.AbstractWorkflowLifecycleEventHandler:[47] - Begin fire
workflow flow_condition_import_no_environment-20251225095821727
LifecycleEvent[WorkflowTopologyLogicalTransitionWithTaskFinishLifecycleEvent{task=sh01taskState=FAILURE}]
with state: RUNNING_EXECUTION
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
