Skip to content

[Bug] [Master] If only the current node is run in the workflow, the workflow cannot be completed #17530

@det101

Description

@det101

Search before asking

  • I had searched in the issues and found no similar issues.

What happened

Only the current node is running in the workflow, and the workflow instance has been completed, but the workflow is still running

What you expected to happen

Normally, once the current node is completed, the workflow is fully completed

How to reproduce

Create two nodes, where node A is upstream of node B. Right click and select node A to run, and choose to execute only the current node

Anything else

[WI-1][TI-0] - 2025-09-22 19:04:10.038 ERROR [ds-workflow-eventbus-worker-2] o.a.d.s.m.e.WorkflowEventBusFireWorker:[88] - Fire event failed for WorkflowExecuteRunnable: ec-20250922190357962
org.apache.dolphinscheduler.server.master.engine.exceptions.WorkflowEventFireException: Failed to fire event: WorkflowTopologyLogicalTransitionWithTaskFinishLifecycleEvent{task=ec1taskState=SUCCESS}
        at org.apache.dolphinscheduler.server.master.engine.WorkflowEventBusFireWorker.doFireSingleWorkflowEventBus(WorkflowEventBusFireWorker.java:133)
        at org.apache.dolphinscheduler.server.master.engine.WorkflowEventBusFireWorker.fireAllRegisteredEvent(WorkflowEventBusFireWorker.java:86)
        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: java.lang.NullPointerException: null
        at org.apache.dolphinscheduler.server.master.engine.graph.WorkflowExecutionGraph.isTaskExecutionRunnableActive(WorkflowExecutionGraph.java:146)
        at org.apache.dolphinscheduler.server.master.engine.graph.WorkflowExecutionGraph.isTriggerConditionMet(WorkflowExecutionGraph.java:184)
        at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:174)
        at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
        at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
        at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
        at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708)
        at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
        at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:566)
        at org.apache.dolphinscheduler.server.master.engine.workflow.statemachine.AbstractWorkflowStateAction.triggerTasks(AbstractWorkflowStateAction.java:78)
        at org.apache.dolphinscheduler.server.master.engine.workflow.statemachine.AbstractWorkflowStateAction.tryToTriggerSuccessorsAfterTaskFinish(AbstractWorkflowStateAction.java:131)
        at org.apache.dolphinscheduler.server.master.engine.workflow.statemachine.WorkflowRunningStateAction.onTopologyLogicalTransitionEvent(WorkflowRunningStateAction.java:56)
        at org.apache.dolphinscheduler.server.master.engine.workflow.lifecycle.handler.WorkflowTopologyLogicalTransitionWithTaskFinishLifecycleEventHandler.handle(WorkflowTopologyLogicalTransitionWithTaskFinishLifecycleEventHandler.java:38)
        at org.apache.dolphinscheduler.server.master.engine.workflow.lifecycle.handler.WorkflowTopologyLogicalTransitionWithTaskFinishLifecycleEventHandler.handle(WorkflowTopologyLogicalTransitionWithTaskFinishLifecycleEventHandler.java:1)
        at org.apache.dolphinscheduler.server.master.engine.workflow.lifecycle.handler.AbstractWorkflowLifecycleEventHandler.handle(AbstractWorkflowLifecycleEventHandler.java:51)
        at org.apache.dolphinscheduler.server.master.engine.workflow.lifecycle.handler.AbstractWorkflowLifecycleEventHandler.handle(AbstractWorkflowLifecycleEventHandler.java:1)
        at org.apache.dolphinscheduler.server.master.engine.WorkflowEventBusFireWorker.doFireSingleEvent(WorkflowEventBusFireWorker.java:144)
        at org.apache.dolphinscheduler.server.master.engine.WorkflowEventBusFireWorker.doFireSingleWorkflowEventBus(WorkflowEventBusFireWorker.java:122)
        ... 8 common frames omitted

Version

dev

Are you willing to submit PR?

  • Yes I am willing to submit a PR!

Code of Conduct

Metadata

Metadata

Assignees

Labels

backendbugSomething isn't working

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions