[Bug] [Master] MethodInvocationException: Cannot find the ServerMethodInvoker

[wustlz]

Search before asking

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

What happened

When run sub-workflow tasks, We found some exception logs on the master server.

[WI-48][TI-72] - [ERROR] 2023-12-13 10:16:13.129 +0800 org.apache.dolphinscheduler.server.master.processor.queue.TaskExecuteRunnable:[64] - Handle task event error, this event will be removed, event: TaskEvent(taskInstanceId=72, workerAddress=10.248.27.208:5678, state=TaskExecutionStatus{code=7, desc='success'}, startTime=Wed Dec 13 10:16:02 CST 2023, endTime=Wed Dec 13 10:16:12 CST 2023, executePath=null, logPath=/root/Desktop/project/dolphin-scheduler/logs/20231213/11894994339744/2/48/72.log, processId=0, appIds=null, event=RESULT, varPool=[], cacheTaskInstanceId=0, processInstanceId=48)
org.apache.dolphinscheduler.server.master.event.TaskEventHandleError: Handle task result event error, save taskInstance to db error
at org.apache.dolphinscheduler.server.master.event.TaskResultEventHandler.handleTaskEvent(TaskResultEventHandler.java:107)
at org.apache.dolphinscheduler.server.master.processor.queue.TaskExecuteRunnable.run(TaskExecuteRunnable.java:56)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
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:748)
Caused by: org.apache.dolphinscheduler.extract.base.exception.MethodInvocationException: Cannot find the ServerMethodInvoker of public abstract void org.apache.dolphinscheduler.extract.worker.ITaskInstanceExecutionEventAckListener.handleTaskInstanceExecutionFinishEventAck(org.apache.dolphinscheduler.extract.worker.transportor.TaskInstanceExecutionFinishEventAck)
at org.apache.dolphinscheduler.extract.base.exception.MethodInvocationException.of(MethodInvocationException.java:27)
at org.apache.dolphinscheduler.extract.base.client.SyncClientMethodInvoker$$M$_jr_3B07A0D62944F207_2.invoke(SyncClientMethodInvoker.java:48)

What you expected to happen

the workflowInstance

we find the logs in the file[o.a.d.server.master.runner.listener.TaskInstanceExecutionResultEventListenFunction]

[WI-48][TI-71] - [INFO] 2023-12-13 10:16:01.738 +0800 o.a.d.server.master.runner.listener.TaskInstanceExecutionResultEventListenFunction:[45] - Received TaskInstanceExecutionFinishEvent: TaskEvent(taskInstanceId=71, workerAddress=10.248.27.208:1234, state=TaskExecutionStatus{code=7, desc='success'}, startTime=Wed Dec 13 10:16:00 CST 2023, endTime=Wed Dec 13 10:16:01 CST 2023, executePath=/tmp/dolphinscheduler/exec/process/default/11885390657984/11894994339744_2/48/71, logPath=/root/Desktop/project/dolphin-scheduler/logs/20231213/11894994339744/2/48/71.log, processId=13375, appIds=null, event=RESULT, varPool=[], cacheTaskInstanceId=0, processInstanceId=48)

[WI-48][TI-72] - [INFO] 2023-12-13 10:16:12.377 +0800 o.a.d.server.master.runner.listener.TaskInstanceExecutionResultEventListenFunction:[45] - Received TaskInstanceExecutionFinishEvent: TaskEvent(taskInstanceId=72, workerAddress=10.248.27.208:5678, state=TaskExecutionStatus{code=7, desc='success'}, startTime=Wed Dec 13 10:16:02 CST 2023, endTime=Wed Dec 13 10:16:12 CST 2023, executePath=null, logPath=/root/Desktop/project/dolphin-scheduler/logs/20231213/11894994339744/2/48/72.log, processId=0, appIds=null, event=RESULT, varPool=[], cacheTaskInstanceId=0, processInstanceId=48)

[WI-49][TI-73] - [INFO] 2023-12-13 10:16:03.725 +0800 o.a.d.server.master.runner.listener.TaskInstanceExecutionResultEventListenFunction:[45] - Received TaskInstanceExecutionFinishEvent: TaskEvent(taskInstanceId=73, workerAddress=10.248.27.208:1234, state=TaskExecutionStatus{code=7, desc='success'}, startTime=Wed Dec 13 10:16:02 CST 2023, endTime=Wed Dec 13 10:16:03 CST 2023, executePath=/tmp/dolphinscheduler/exec/process/default/11885390657984/11894978424096_1/49/73, logPath=/root/Desktop/project/dolphin-scheduler/logs/20231213/11894978424096/1/49/73.log, processId=13397, appIds=null, event=RESULT, varPool=[], cacheTaskInstanceId=0, processInstanceId=49)

when Received TaskInstanceExecutionFinishEvent, the workerAddress of 'taskInstance-72' is '10.248.27.208:5678', it's a masterAdderess, Is there any problem with this?

How to reproduce

Define a workflow with sub-process

Anything else

No response

Version

dev

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]

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.