[Bug] [master] TASK_STATE_CHANGE executeStatus: RU NNING_EXECUTION task instance id: XXX process instance id: XXX context: null

[seagle-yuan]

Search before asking

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

What happened

[INFO] 2021-12-20 15:28:44.034 org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteThread:[286] - process event: State Event :key: null type: TASK_STATE_CHANGE executeStatus: RU
NNING_EXECUTION task instance id: 102 process instance id: 28 context: null
[ERROR] 2021-12-20 15:28:44.035 org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteThread:[249] - state handle error:
java.lang.NullPointerException: null
[ERROR] 2021-12-20 15:28:44.035 org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteThread:[249] - state handle error:
java.lang.NullPointerException: null
[INFO] 2021-12-20 15:28:44.035 org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteThread:[286] - process event: State Event :key: null type: TASK_STATE_CHANGE executeStatus: RU
NNING_EXECUTION task instance id: 104 process instance id: 29 context: null
[INFO] 2021-12-20 15:28:44.035 org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteThread:[286] - process event: State Event :key: null type: TASK_STATE_CHANGE executeStatus: RU
NNING_EXECUTION task instance id: 106 process instance id: 27 context: null
[ERROR] 2021-12-20 15:28:44.035 org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteThread:[249] - state handle error:
java.lang.NullPointerException: null
[INFO] 2021-12-20 15:28:44.035 org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteThread:[286] - process event: State Event :key: null type: TASK_STATE_CHANGE executeStatus: RU
NNING_EXECUTION task instance id: 102 process instance id: 28 context: null
[ERROR] 2021-12-20 15:28:44.035 org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteThread:[249] - state handle error:
java.lang.NullPointerException: null
[ERROR] 2021-12-20 15:28:44.035 org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteThread:[249] - state handle error:
java.lang.NullPointerException: null
[INFO] 2021-12-20 15:28:44.035 org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteThread:[286] - process event: State Event :key: null type: TASK_STATE_CHANGE executeStatus: RU
NNING_EXECUTION task instance id: 104 process instance id: 29 context: null

What you expected to happen

it's always write this error log

How to reproduce

1

Anything else

No response

Version

2.0.0

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

[github-actions]

Hi:

• Thank you for your feedback, we have received your issue, Please wait patiently for a reply.
• In order for us to understand your request as soon as possible, please provide detailed information、version or pictures.
• If you haven't received a reply for a long time, you can subscribe to the developer's email，Mail subscription steps reference https://dolphinscheduler.apache.org/en-us/community/development/subscribe.html ,Then write the issue URL in the email content and send question to dev@dolphinscheduler.apache.org.

[lenboo]

@seagle-yuan
I think we need more details for this problem :

• When did it happened?
• What's the state of workflow/tasks?
• What's the task types of the workflow?
  Please reopen it when you supply more details.

[kangweihao0321]

I found this problem also because I had a task executing when restarting the cluster. It doesn't happen that I restart the task I'm doing after I stop it.

[xialinlin101]

I found that this error occurs after stopping the task and deleting the process instance，The corresponding task instance is also deleted.
The error occurred in： org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteThread
private boolean taskStateChangeHandler(StateEvent stateEvent) {
TaskInstance task = processService.findTaskInstanceById(stateEvent.getTaskInstanceId());
if (task.getState().typeIsFinished()) {
taskFinished(task);
} else if (activeTaskProcessorMaps.containsKey(stateEvent.getTaskInstanceId())) {
ITaskProcessor iTaskProcessor = activeTaskProcessorMaps.get(stateEvent.getTaskInstanceId());
iTaskProcessor.action(TaskAction.RUN);

        if (iTaskProcessor.taskState().typeIsFinished()) {
            task = processService.findTaskInstanceById(stateEvent.getTaskInstanceId());
            taskFinished(task);
        }
    } else {
        logger.error("state handler error: {}", stateEvent.toString());
    }
    return true;
}

[github-actions]

This issue has been automatically marked as stale because it has not had recent activity for 30 days. It will be closed in next 7 days if no further activity occurs.

[github-actions]

This issue has been closed because it has not received response for too long time. You could reopen it if you encountered similar problems in the future.