Apache DolphinScheduler调度系统在调度任务时中断。我在网上找了很长时间。但是没有用。请帮助或试着给出一些想法如何实现这一目标。
[INFO] 2021-10-20 10:00:00.281 org.apache.dolphinscheduler.server.master.runner.MasterExecThread:[792] - add task to stand by list: dal_xwj_makeup_activity
[INFO] 2021-10-20 10:00:00.282 org.apache.dolphinscheduler.server.master.runner.MasterTaskExecThread:[216] - task ready to submit: TaskInstance{id=5340, name='dal_xwj_makeup_activity', task
Type='SHELL', processDefinitionId=5, processInstanceId=353, processInstanceName='null', taskJson='{"conditionResult":"{"successNode":[""],"failedNode":[""]}","conditionsTask":false,
"depList":[],"dependence":"{}","forbidden":false,"id":"tasks-29147","maxRetryTimes":1,"name":"dal_xwj_makeup_activity","params":"{"rawScript":"echo \"makeup_making_machine running
。。。\"\n/opt/imsxwj/anaconda3/bin/python dal_xiwujie/makeup_making_machine.py","localParams":[],"resourceList":[{"res":"dal_xiwujie/makeup_making_machine.py","name":"makeup
_making_machine.py","id":127}]}","preTasks":"[]","retryInterval":1,"runFlag":"NORMAL","taskInstancePriority":"MEDIUM","taskTimeoutParameter":{"enable":false,"interval":0},"timeout":"{"e
nable":false,"strategy":""}","type":"SHELL","workerGroup":"default"}', state=SUBMITTED_SUCCESS, submitTime=Wed Oct 20 10:00:00 CST 2021, startTime=null, endTime=null, host='null', exec
utePath='null', logPath='null', retryTimes=0, alertFlag=NO, processInstance=null, processDefine=null, pid=0, appLink='null', flag=YES, dependency='null', duration=null, maxRetryTimes=1, ret
ryInterval=1, taskInstancePriority=MEDIUM, processInstancePriority=MEDIUM, dependentResult='null', workerGroup='hdp', executorId=2, executorName='null'}
[INFO] 2021-10-20 10:00:00.282 org.apache.dolphinscheduler.server.master.runner.MasterExecThread:[805] - remove task from stand by list: dal_xwj_makeup_activity
[ERROR] 2021-10-20 10:00:00.282 org.apache.dolphinscheduler.server.master.runner.MasterTaskExecThread:[230] - submit task Exception:
java.lang.NullPointerException: null
at org.apache.dolphinscheduler.server.master.runner.MasterBaseTaskExecThread.dispatchTask(MasterBaseTaskExecThread.java:221)
at org.apache.dolphinscheduler.server.master.runner.MasterBaseTaskExecThread.submit(MasterBaseTaskExecThread.java:175)
at org.apache.dolphinscheduler.server.master.runner.MasterTaskExecThread.submitWaitComplete(MasterTaskExecThread.java:92)
at org.apache.dolphinscheduler.server.master.runner.MasterBaseTaskExecThread.call(MasterBaseTaskExecThread.java:272)
at org.apache.dolphinscheduler.server.master.runner.MasterBaseTaskExecThread.call(MasterBaseTaskExecThread.java:50)
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)
[INFO] 2021-10-20 10:00:00.288 org.apache.dolphinscheduler.service.process.ProcessService:[845] - start submit task : dal_xwj_makeup_activity, instance id:354, state: RUNNING_EXECUTION
[ERROR] 2021-10-20 10:00:00.289 org.apache.dolphinscheduler.server.master.runner.MasterTaskExecThread:[231] - task error : %s
[ERROR] 2021-10-20 10:00:00.289 org.apache.dolphinscheduler.server.master.runner.MasterTaskExecThread:[183] - task commit failed , taskId 5340 has already retry 1 times, please check哪个版本?是否删除流程实例?我检查221行:
/**
* taskPriority
*/
TaskPriority taskPriority = buildTaskPriority(processInstance.getProcessInstancePriority().getCode(),
processInstance.getId(),
...
如果您删除流程实例，将会有一个NPE。