0

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

4

1 回答 1

1

哪个版本？你删除流程实例吗？我检查了 221 行：


            /**
             *  taskPriority
             */
            TaskPriority taskPriority = buildTaskPriority(processInstance.getProcessInstancePriority().getCode(),
                    processInstance.getId(),
...

如果你删除流程实例，就会有一个 NPE。

于 2021-10-25T10:47:03.553 回答