xiangtao commented on issue #14026:
URL:
https://github.com/apache/dolphinscheduler/issues/14026#issuecomment-1562173596
> Could you please provide the workflow log?
i have not reproduce , i view code , i found
WorkflowExecuteRunnable.getProcessInstanceState
`// process failure
if (processFailed()) {
logger.info("The workflowInstance is failed, the workflow status
is {}", WorkflowExecutionStatus.FAILURE);
return WorkflowExecutionStatus.FAILURE;
}`
processFailed() method return true.
> bellow
i find workflow_instance_id = 693038 log .
[INFO] 2023-04-16 22:34:00.630 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[690]
- [WorkflowInstance-693038][TaskInstance-0] - workflowStatue changed to
:INITIALIZE_DAG
[INFO] 2023-04-16 22:34:00.630 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[875]
- [WorkflowInstance-693038][TaskInstance-0] - The current workflowInstance is a
newly running workflowInstance
[INFO] 2023-04-16 22:34:00.630 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[917]
- [WorkflowInstance-693038][TaskInstance-0] - Initialize task queue,
dependFailedTaskSet: [], completeTaskMap: {}, errorTaskMap: {}
[INFO] 2023-04-16 22:34:00.630 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[695]
- [WorkflowInstance-693038][TaskInstance-0] - workflowStatue changed to
:INITIALIZE_QUEUE
[INFO] 2023-04-16 22:34:00.630 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[1729]
- [WorkflowInstance-693038][TaskInstance-0] - Add task to stand by list, task
name:databus_http_douyin_compass_live_cumulative_data_dhi_zycp2, task id:null,
task code:8879185628736
[INFO] 2023-04-16 22:34:00.630 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[1729]
- [WorkflowInstance-693038][TaskInstance-0] - Add task to stand by list, task
name:databus_http_douyin_compass_live_cumulative_data_dhi_mlsh2, task id:null,
task code:8879185631680
[INFO] 2023-04-16 22:34:00.630 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[1729]
- [WorkflowInstance-693038][TaskInstance-0] - Add task to stand by list, task
name:databus_http_douyin_compass_live_cumulative_data_dhi_ts2, task id:null,
task code:8879185634624
[INFO] 2023-04-16 22:34:00.630 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[1729]
- [WorkflowInstance-693038][TaskInstance-0] - Add task to stand by list, task
name:databus_http_douyin_compass_live_cumulative_data_dhi_dfzx2, task id:null,
task code:8879185625920
[INFO] 2023-04-16 22:34:00.630 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[1729]
- [WorkflowInstance-693038][TaskInstance-0] - Add task to stand by list, task
name:databus_http_douyin_compass_live_cumulative_data_dhi_qjj2, task id:null,
task code:8879185622720
[INFO] 2023-04-16 22:34:00.630 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[1836]
- [WorkflowInstance-693038][TaskInstance-0] - The dependResult of task
databus_http_douyin_compass_live_cumulative_data_dhi_zycp2 is success, so ready
to submit to execute
[WARN] 2023-04-16 22:34:00.631 +0800
com.zaxxer.hikari.pool.ProxyConnection:[182] -
[WorkflowInstance-693038][TaskInstance-0] - DolphinScheduler - Connection
com.mysql.cj.jdbc.ConnectionImpl@c236e4f marked as broken because of
SQLSTATE(08S01), ErrorCode(0)
[ERROR] 2023-04-16 22:34:00.632 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[1015]
- [WorkflowInstance-693038][TaskInstance-0] - Submit standby task
databus_http_douyin_compass_live_cumulative_data_dhi_zycp2 error, taskCode:
8879185628736
[ERROR] 2023-04-16 22:34:00.633 +0800
org.apache.dolphinscheduler.server.master.event.WorkflowStartEventHandler:[72]
- [WorkflowInstance-0][TaskInstance-0] - Failed to submit the workflow
instance, will resend the workflow start event:
WorkflowEvent(workflowEventType=START_WORKFLOW, workflowInstanceId=693038)
[INFO] 2023-04-16 22:34:00.633 +0800
org.apache.dolphinscheduler.server.master.event.WorkflowEventQueue:[38] -
[WorkflowInstance-0][TaskInstance-0] - Added workflow event to workflowEvent
queue, event: WorkflowEvent(workflowEventType=START_WORKFLOW,
workflowInstanceId=693038)
[INFO] 2023-04-16 22:34:00.633 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowEventLooper:[78] -
[WorkflowInstance-693038][TaskInstance-0] - Workflow event looper receive a
workflow event: WorkflowEvent(workflowEventType=START_WORKFLOW,
workflowInstanceId=693038), will handle this
[INFO] 2023-04-16 22:34:00.633 +0800
org.apache.dolphinscheduler.server.master.event.WorkflowStartEventHandler:[54]
- [WorkflowInstance-693038][TaskInstance-0] - Handle workflow start event,
begin to start a workflow, event:
WorkflowEvent(workflowEventType=START_WORKFLOW, workflowInstanceId=693038)
[INFO] 2023-04-16 22:34:00.634 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[1729]
- [WorkflowInstance-693038][TaskInstance-0] - Add task to stand by list, task
name:databus_http_douyin_compass_live_cumulative_data_dhi_zycp2, task id:null,
task code:8879185628736
[WARN] 2023-04-16 22:34:00.634 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[1347]
- [WorkflowInstance-693038][TaskInstance-0] - Task is already at submit queue,
taskInstanceId: null
[WARN] 2023-04-16 22:34:00.634 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[1347]
- [WorkflowInstance-693038][TaskInstance-0] - Task is already at submit queue,
taskInstanceId: null
[WARN] 2023-04-16 22:34:00.634 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[1347]
- [WorkflowInstance-693038][TaskInstance-0] - Task is already at submit queue,
taskInstanceId: null
[WARN] 2023-04-16 22:34:00.634 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[1347]
- [WorkflowInstance-693038][TaskInstance-0] - Task is already at submit queue,
taskInstanceId: null
[INFO] 2023-04-16 22:34:00.634 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[1836]
- [WorkflowInstance-693038][TaskInstance-0] - The dependResult of task
databus_http_douyin_compass_live_cumulative_data_dhi_qjj2 is success, so ready
to submit to execute
[INFO] 2023-04-16 22:34:00.636 +0800
org.apache.dolphinscheduler.service.process.ProcessServiceImpl:[1312] -
[WorkflowInstance-693038][TaskInstance-0] - Start save taskInstance to database
: databus_http_douyin_compass_live_cumulative_data_dhi_qjj2, processInstance
id:693038, state: WorkflowExecutionStatus{code=1, desc='running'}
[INFO] 2023-04-16 22:34:00.639 +0800
org.apache.dolphinscheduler.service.process.ProcessServiceImpl:[1330] -
[WorkflowInstance-693038][TaskInstance-0] - End save taskInstance to db
successfully:3125987, taskInstanceName:
databus_http_douyin_compass_live_cumulative_data_dhi_qjj2, taskInstance
state:TaskExecutionStatus{code=0, desc='submit success'},
processInstanceId:693038, processInstanceState: WorkflowExecutionStatus{code=1,
desc='running'}
[INFO] 2023-04-16 22:34:00.639 +0800 TaskLogLogger-class
org.apache.dolphinscheduler.server.master.runner.task.CommonTaskProcessor:[109]
- [WorkflowInstance-693038][TaskInstance-3125987] - Task
databus_http_douyin_compass_live_cumulative_data_dhi_qjj2 is ready to dispatch
to worker
[INFO] 2023-04-16 22:34:00.642 +0800 TaskLogLogger-class
org.apache.dolphinscheduler.server.master.runner.task.CommonTaskProcessor:[125]
- [WorkflowInstance-693038][TaskInstance-3125987] - Task
databus_http_douyin_compass_live_cumulative_data_dhi_qjj2 is submitted to
priority queue success by master
[INFO] 2023-04-16 22:34:00.642 +0800
org.apache.dolphinscheduler.server.master.runner.StateWheelExecuteThread:[172]
- [WorkflowInstance-693038][TaskInstance-3125987] - Adding task instance into
timeout check list
[INFO] 2023-04-16 22:34:00.642 +0800
org.apache.dolphinscheduler.server.master.runner.StateWheelExecuteThread:[222]
- [WorkflowInstance-693038][TaskInstance-3125987] - Adding task instance into
state check list
[INFO] 2023-04-16 22:34:00.643 +0800
org.apache.dolphinscheduler.service.process.ProcessServiceImpl:[1312] -
[WorkflowInstance-0][TaskInstance-0] - Start save taskInstance to database :
databus_http_douyin_compass_live_cumulative_data_dhi_zycp2, processInstance
id:693038, state: WorkflowExecutionStatus{code=1, desc='running'}
[INFO] 2023-04-16 22:34:00.644 +0800
org.apache.dolphinscheduler.server.master.processor.TaskExecuteRunningProcessor:[58]
- [WorkflowInstance-0][TaskInstance-0] - taskExecuteRunningCommand:
TaskExecuteRunningCommand(super=BaseCommand(messageSenderAddress=172.18.224.10:1234,
messageReceiverAddress=172.18.224.7:5678, messageSendTime=1681655640644),
taskInstanceId=3125987, processInstanceId=693038, startTime=Sun Apr 16 22:34:00
CST 2023, host=172.18.224.10:1234, status=TaskExecutionStatus{code=1,
desc='running'},
logPath=/tol/app/dolphinscheduler/worker-server/logs/20230416/8514884452928_276-693038-3125987.log,
executePath=null, processId=0, appIds=null)
[INFO] 2023-04-16 22:34:00.646 +0800
org.apache.dolphinscheduler.service.process.ProcessServiceImpl:[1330] -
[WorkflowInstance-0][TaskInstance-0] - End save taskInstance to db
successfully:3125988, taskInstanceName:
databus_http_douyin_compass_live_cumulative_data_dhi_zycp2, taskInstance
state:TaskExecutionStatus{code=0, desc='submit success'},
processInstanceId:693038, processInstanceState: WorkflowExecutionStatus{code=1,
desc='running'}
[INFO] 2023-04-16 22:34:00.646 +0800 TaskLogLogger-class
org.apache.dolphinscheduler.server.master.runner.task.CommonTaskProcessor:[109]
- [WorkflowInstance-693038][TaskInstance-3125988] - Task
databus_http_douyin_compass_live_cumulative_data_dhi_zycp2 is ready to dispatch
to worker
[INFO] 2023-04-16 22:34:00.648 +0800 TaskLogLogger-class
org.apache.dolphinscheduler.server.master.runner.task.CommonTaskProcessor:[125]
- [WorkflowInstance-693038][TaskInstance-3125988] - Task
databus_http_douyin_compass_live_cumulative_data_dhi_zycp2 is submitted to
priority queue success by master
[INFO] 2023-04-16 22:34:00.649 +0800
org.apache.dolphinscheduler.server.master.runner.StateWheelExecuteThread:[172]
- [WorkflowInstance-693038][TaskInstance-3125988] - Adding task instance into
timeout check list
[INFO] 2023-04-16 22:34:00.649 +0800
org.apache.dolphinscheduler.server.master.runner.StateWheelExecuteThread:[222]
- [WorkflowInstance-693038][TaskInstance-3125988] - Adding task instance into
state check list
[INFO] 2023-04-16 22:34:00.650 +0800
org.apache.dolphinscheduler.service.process.ProcessServiceImpl:[1312] -
[WorkflowInstance-0][TaskInstance-0] - Start save taskInstance to database :
databus_http_douyin_compass_live_cumulative_data_dhi_dfzx2, processInstance
id:693038, state: WorkflowExecutionStatus{code=1, desc='running'}
[INFO] 2023-04-16 22:34:00.652 +0800
org.apache.dolphinscheduler.service.process.ProcessServiceImpl:[1330] -
[WorkflowInstance-0][TaskInstance-0] - End save taskInstance to db
successfully:3125989, taskInstanceName:
databus_http_douyin_compass_live_cumulative_data_dhi_dfzx2, taskInstance
state:TaskExecutionStatus{code=0, desc='submit success'},
processInstanceId:693038, processInstanceState: WorkflowExecutionStatus{code=1,
desc='running'}
[INFO] 2023-04-16 22:34:00.652 +0800 TaskLogLogger-class
org.apache.dolphinscheduler.server.master.runner.task.CommonTaskProcessor:[109]
- [WorkflowInstance-693038][TaskInstance-3125989] - Task
databus_http_douyin_compass_live_cumulative_data_dhi_dfzx2 is ready to dispatch
to worker
[INFO] 2023-04-16 22:34:00.653 +0800
org.apache.dolphinscheduler.server.master.processor.TaskExecuteRunningProcessor:[58]
- [WorkflowInstance-0][TaskInstance-0] - taskExecuteRunningCommand:
TaskExecuteRunningCommand(super=BaseCommand(messageSenderAddress=172.18.224.135:1234,
messageReceiverAddress=172.18.224.7:5678, messageSendTime=1681655640652),
taskInstanceId=3125988, processInstanceId=693038, startTime=Sun Apr 16 22:34:00
CST 2023, host=172.18.224.135:1234, status=TaskExecutionStatus{code=1,
desc='running'},
logPath=/tol/app/dolphinscheduler/worker-server/logs/20230416/8514884452928_276-693038-3125988.log,
executePath=null, processId=0, appIds=null)
[INFO] 2023-04-16 22:34:00.655 +0800 TaskLogLogger-class
org.apache.dolphinscheduler.server.master.runner.task.CommonTaskProcessor:[125]
- [WorkflowInstance-693038][TaskInstance-3125989] - Task
databus_http_douyin_compass_live_cumulative_data_dhi_dfzx2 is submitted to
priority queue success by master
[INFO] 2023-04-16 22:34:00.655 +0800
org.apache.dolphinscheduler.server.master.runner.StateWheelExecuteThread:[172]
- [WorkflowInstance-693038][TaskInstance-3125989] - Adding task instance into
timeout check list
[INFO] 2023-04-16 22:34:00.655 +0800
org.apache.dolphinscheduler.server.master.runner.StateWheelExecuteThread:[222]
- [WorkflowInstance-693038][TaskInstance-3125989] - Adding task instance into
state check list
[INFO] 2023-04-16 22:34:00.656 +0800
org.apache.dolphinscheduler.service.process.ProcessServiceImpl:[1312] -
[WorkflowInstance-0][TaskInstance-0] - Start save taskInstance to database :
databus_http_douyin_compass_live_cumulative_data_dhi_ts2, processInstance
id:693038, state: WorkflowExecutionStatus{code=1, desc='running'}
[INFO] 2023-04-16 22:34:00.657 +0800
org.apache.dolphinscheduler.server.master.processor.TaskExecuteRunningProcessor:[58]
- [WorkflowInstance-0][TaskInstance-0] - taskExecuteRunningCommand:
TaskExecuteRunningCommand(super=BaseCommand(messageSenderAddress=172.18.224.10:1234,
messageReceiverAddress=172.18.224.7:5678, messageSendTime=1681655640656),
taskInstanceId=3125989, processInstanceId=693038, startTime=Sun Apr 16 22:34:00
CST 2023, host=172.18.224.10:1234, status=TaskExecutionStatus{code=1,
desc='running'},
logPath=/tol/app/dolphinscheduler/worker-server/logs/20230416/8514884452928_276-693038-3125989.log,
executePath=null, processId=0, appIds=null)
[INFO] 2023-04-16 22:34:00.659 +0800
org.apache.dolphinscheduler.service.process.ProcessServiceImpl:[1330] -
[WorkflowInstance-0][TaskInstance-0] - End save taskInstance to db
successfully:3125990, taskInstanceName:
databus_http_douyin_compass_live_cumulative_data_dhi_ts2, taskInstance
state:TaskExecutionStatus{code=0, desc='submit success'},
processInstanceId:693038, processInstanceState: WorkflowExecutionStatus{code=1,
desc='running'}
[INFO] 2023-04-16 22:34:00.659 +0800 TaskLogLogger-class
org.apache.dolphinscheduler.server.master.runner.task.CommonTaskProcessor:[109]
- [WorkflowInstance-693038][TaskInstance-3125990] - Task
databus_http_douyin_compass_live_cumulative_data_dhi_ts2 is ready to dispatch
to worker
[INFO] 2023-04-16 22:34:00.662 +0800 TaskLogLogger-class
org.apache.dolphinscheduler.server.master.runner.task.CommonTaskProcessor:[125]
- [WorkflowInstance-693038][TaskInstance-3125990] - Task
databus_http_douyin_compass_live_cumulative_data_dhi_ts2 is submitted to
priority queue success by master
[INFO] 2023-04-16 22:34:00.662 +0800
org.apache.dolphinscheduler.server.master.runner.StateWheelExecuteThread:[172]
- [WorkflowInstance-693038][TaskInstance-3125990] - Adding task instance into
timeout check list
[INFO] 2023-04-16 22:34:00.662 +0800
org.apache.dolphinscheduler.server.master.runner.StateWheelExecuteThread:[222]
- [WorkflowInstance-693038][TaskInstance-3125990] - Adding task instance into
state check list
[INFO] 2023-04-16 22:34:00.663 +0800
org.apache.dolphinscheduler.service.process.ProcessServiceImpl:[1312] -
[WorkflowInstance-0][TaskInstance-0] - Start save taskInstance to database :
databus_http_douyin_compass_live_cumulative_data_dhi_mlsh2, processInstance
id:693038, state: WorkflowExecutionStatus{code=1, desc='running'}
[INFO] 2023-04-16 22:34:00.664 +0800
org.apache.dolphinscheduler.server.master.processor.TaskExecuteRunningProcessor:[58]
- [WorkflowInstance-0][TaskInstance-0] - taskExecuteRunningCommand:
TaskExecuteRunningCommand(super=BaseCommand(messageSenderAddress=172.18.224.10:1234,
messageReceiverAddress=172.18.224.7:5678, messageSendTime=1681655640663),
taskInstanceId=3125990, processInstanceId=693038, startTime=Sun Apr 16 22:34:00
CST 2023, host=172.18.224.10:1234, status=TaskExecutionStatus{code=1,
desc='running'},
logPath=/tol/app/dolphinscheduler/worker-server/logs/20230416/8514884452928_276-693038-3125990.log,
executePath=null, processId=0, appIds=null)
[INFO] 2023-04-16 22:34:00.665 +0800
org.apache.dolphinscheduler.service.process.ProcessServiceImpl:[1330] -
[WorkflowInstance-0][TaskInstance-0] - End save taskInstance to db
successfully:3125991, taskInstanceName:
databus_http_douyin_compass_live_cumulative_data_dhi_mlsh2, taskInstance
state:TaskExecutionStatus{code=0, desc='submit success'},
processInstanceId:693038, processInstanceState: WorkflowExecutionStatus{code=1,
desc='running'}
[INFO] 2023-04-16 22:34:00.666 +0800 TaskLogLogger-class
org.apache.dolphinscheduler.server.master.runner.task.CommonTaskProcessor:[109]
- [WorkflowInstance-693038][TaskInstance-3125991] - Task
databus_http_douyin_compass_live_cumulative_data_dhi_mlsh2 is ready to dispatch
to worker
[INFO] 2023-04-16 22:34:00.668 +0800 TaskLogLogger-class
org.apache.dolphinscheduler.server.master.runner.task.CommonTaskProcessor:[125]
- [WorkflowInstance-693038][TaskInstance-3125991] - Task
databus_http_douyin_compass_live_cumulative_data_dhi_mlsh2 is submitted to
priority queue success by master
[INFO] 2023-04-16 22:34:00.668 +0800
org.apache.dolphinscheduler.server.master.runner.StateWheelExecuteThread:[172]
- [WorkflowInstance-693038][TaskInstance-3125991] - Adding task instance into
timeout check list
[INFO] 2023-04-16 22:34:00.668 +0800
org.apache.dolphinscheduler.server.master.runner.StateWheelExecuteThread:[222]
- [WorkflowInstance-693038][TaskInstance-3125991] - Adding task instance into
state check list
[INFO] 2023-04-16 22:34:00.672 +0800
org.apache.dolphinscheduler.server.master.processor.TaskExecuteRunningProcessor:[58]
- [WorkflowInstance-0][TaskInstance-0] - taskExecuteRunningCommand:
TaskExecuteRunningCommand(super=BaseCommand(messageSenderAddress=172.18.224.135:1234,
messageReceiverAddress=172.18.224.7:5678, messageSendTime=1681655640671),
taskInstanceId=3125991, processInstanceId=693038, startTime=Sun Apr 16 22:34:00
CST 2023, host=172.18.224.135:1234, status=TaskExecutionStatus{code=1,
desc='running'},
logPath=/tol/app/dolphinscheduler/worker-server/logs/20230416/8514884452928_276-693038-3125991.log,
executePath=null, processId=0, appIds=null)
[INFO] 2023-04-16 22:34:00.756 +0800
org.apache.dolphinscheduler.server.master.processor.queue.TaskExecuteRunnable:[56]
- [WorkflowInstance-693038][TaskInstance-3125987] - Handle task event begin:
TaskEvent(taskInstanceId=3125987, workerAddress=172.18.224.10:1234, state=null,
startTime=null, endTime=null, executePath=null, logPath=null, processId=0,
appIds=null, event=DISPATCH, varPool=null, channel=null,
processInstanceId=693038)
[INFO] 2023-04-16 22:34:00.759 +0800
org.apache.dolphinscheduler.server.master.processor.queue.TaskExecuteRunnable:[59]
- [WorkflowInstance-693038][TaskInstance-3125987] - Handle task event
finished: TaskEvent(taskInstanceId=3125987, workerAddress=172.18.224.10:1234,
state=null, startTime=null, endTime=null, executePath=null, logPath=null,
processId=0, appIds=null, event=DISPATCH, varPool=null, channel=null,
processInstanceId=693038)
[INFO] 2023-04-16 22:34:00.759 +0800
org.apache.dolphinscheduler.server.master.processor.queue.TaskExecuteRunnable:[56]
- [WorkflowInstance-693038][TaskInstance-3125987] - Handle task event begin:
TaskEvent(taskInstanceId=3125987, workerAddress=172.18.224.10:1234,
state=TaskExecutionStatus{code=1, desc='running'}, startTime=Sun Apr 16
22:34:00 CST 2023, endTime=null, executePath=null,
logPath=/tol/app/dolphinscheduler/worker-server/logs/20230416/8514884452928_276-693038-3125987.log,
processId=0, appIds=null, event=RUNNING, varPool=null, channel=[id:
0x186d1c86, L:/172.18.224.7:5678 - R:/172.18.224.10:59176],
processInstanceId=693038)
[INFO] 2023-04-16 22:34:00.761 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteThreadPool:[97]
- [WorkflowInstance-693038][TaskInstance-3125987] - Submit state event success,
stateEvent: TaskStateEvent(processInstanceId=693038, taskInstanceId=3125987,
taskCode=0, status=TaskExecutionStatus{code=1, desc='running'},
type=TASK_STATE_CHANGE, key=null, channel=null, context=null)
[INFO] 2023-04-16 22:34:00.762 +0800
org.apache.dolphinscheduler.server.master.processor.queue.TaskExecuteRunnable:[59]
- [WorkflowInstance-693038][TaskInstance-3125987] - Handle task event
finished: TaskEvent(taskInstanceId=3125987, workerAddress=172.18.224.10:1234,
state=TaskExecutionStatus{code=1, desc='running'}, startTime=Sun Apr 16
22:34:00 CST 2023, endTime=null, executePath=null,
logPath=/tol/app/dolphinscheduler/worker-server/logs/20230416/8514884452928_276-693038-3125987.log,
processId=0, appIds=null, event=RUNNING, varPool=null, channel=[id:
0x186d1c86, L:/172.18.224.7:5678 - R:/172.18.224.10:59176],
processInstanceId=693038)
[INFO] 2023-04-16 22:34:00.762 +0800
org.apache.dolphinscheduler.server.master.processor.queue.TaskExecuteRunnable:[56]
- [WorkflowInstance-693038][TaskInstance-3125988] - Handle task event begin:
TaskEvent(taskInstanceId=3125988, workerAddress=172.18.224.135:1234,
state=null, startTime=null, endTime=null, executePath=null, logPath=null,
processId=0, appIds=null, event=DISPATCH, varPool=null, channel=null,
processInstanceId=693038)
[INFO] 2023-04-16 22:34:00.764 +0800
org.apache.dolphinscheduler.server.master.processor.queue.TaskExecuteRunnable:[59]
- [WorkflowInstance-693038][TaskInstance-3125988] - Handle task event
finished: TaskEvent(taskInstanceId=3125988, workerAddress=172.18.224.135:1234,
state=null, startTime=null, endTime=null, executePath=null, logPath=null,
processId=0, appIds=null, event=DISPATCH, varPool=null, channel=null,
processInstanceId=693038)
[INFO] 2023-04-16 22:34:00.764 +0800
org.apache.dolphinscheduler.server.master.processor.queue.TaskExecuteRunnable:[56]
- [WorkflowInstance-693038][TaskInstance-3125988] - Handle task event begin:
TaskEvent(taskInstanceId=3125988, workerAddress=172.18.224.135:1234,
state=TaskExecutionStatus{code=1, desc='running'}, startTime=Sun Apr 16
22:34:00 CST 2023, endTime=null, executePath=null,
logPath=/tol/app/dolphinscheduler/worker-server/logs/20230416/8514884452928_276-693038-3125988.log,
processId=0, appIds=null, event=RUNNING, varPool=null, channel=[id:
0x18f833dd, L:/172.18.224.7:5678 - R:/172.18.224.135:45382],
processInstanceId=693038)
[INFO] 2023-04-16 22:34:00.767 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteThreadPool:[97]
- [WorkflowInstance-693038][TaskInstance-3125988] - Submit state event success,
stateEvent: TaskStateEvent(processInstanceId=693038, taskInstanceId=3125988,
taskCode=0, status=TaskExecutionStatus{code=1, desc='running'},
type=TASK_STATE_CHANGE, key=null, channel=null, context=null)
[INFO] 2023-04-16 22:34:00.767 +0800
org.apache.dolphinscheduler.server.master.processor.queue.TaskExecuteRunnable:[59]
- [WorkflowInstance-693038][TaskInstance-3125988] - Handle task event
finished: TaskEvent(taskInstanceId=3125988, workerAddress=172.18.224.135:1234,
state=TaskExecutionStatus{code=1, desc='running'}, startTime=Sun Apr 16
22:34:00 CST 2023, endTime=null, executePath=null,
logPath=/tol/app/dolphinscheduler/worker-server/logs/20230416/8514884452928_276-693038-3125988.log,
processId=0, appIds=null, event=RUNNING, varPool=null, channel=[id:
0x18f833dd, L:/172.18.224.7:5678 - R:/172.18.224.135:45382],
processInstanceId=693038)
[INFO] 2023-04-16 22:34:00.767 +0800
org.apache.dolphinscheduler.server.master.processor.queue.TaskExecuteRunnable:[56]
- [WorkflowInstance-693038][TaskInstance-3125989] - Handle task event begin:
TaskEvent(taskInstanceId=3125989, workerAddress=172.18.224.10:1234, state=null,
startTime=null, endTime=null, executePath=null, logPath=null, processId=0,
appIds=null, event=DISPATCH, varPool=null, channel=null,
processInstanceId=693038)
[INFO] 2023-04-16 22:34:00.770 +0800
org.apache.dolphinscheduler.server.master.processor.queue.TaskExecuteRunnable:[59]
- [WorkflowInstance-693038][TaskInstance-3125989] - Handle task event
finished: TaskEvent(taskInstanceId=3125989, workerAddress=172.18.224.10:1234,
state=null, startTime=null, endTime=null, executePath=null, logPath=null,
processId=0, appIds=null, event=DISPATCH, varPool=null, channel=null,
processInstanceId=693038)
[INFO] 2023-04-16 22:34:00.770 +0800
org.apache.dolphinscheduler.server.master.processor.queue.TaskExecuteRunnable:[56]
- [WorkflowInstance-693038][TaskInstance-3125989] - Handle task event begin:
TaskEvent(taskInstanceId=3125989, workerAddress=172.18.224.10:1234,
state=TaskExecutionStatus{code=1, desc='running'}, startTime=Sun Apr 16
22:34:00 CST 2023, endTime=null, executePath=null,
logPath=/tol/app/dolphinscheduler/worker-server/logs/20230416/8514884452928_276-693038-3125989.log,
processId=0, appIds=null, event=RUNNING, varPool=null, channel=[id:
0x186d1c86, L:/172.18.224.7:5678 - R:/172.18.224.10:59176],
processInstanceId=693038)
[INFO] 2023-04-16 22:34:00.772 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteThreadPool:[97]
- [WorkflowInstance-693038][TaskInstance-3125989] - Submit state event success,
stateEvent: TaskStateEvent(processInstanceId=693038, taskInstanceId=3125989,
taskCode=0, status=TaskExecutionStatus{code=1, desc='running'},
type=TASK_STATE_CHANGE, key=null, channel=null, context=null)
[INFO] 2023-04-16 22:34:00.772 +0800
org.apache.dolphinscheduler.server.master.processor.queue.TaskExecuteRunnable:[59]
- [WorkflowInstance-693038][TaskInstance-3125989] - Handle task event
finished: TaskEvent(taskInstanceId=3125989, workerAddress=172.18.224.10:1234,
state=TaskExecutionStatus{code=1, desc='running'}, startTime=Sun Apr 16
22:34:00 CST 2023, endTime=null, executePath=null,
logPath=/tol/app/dolphinscheduler/worker-server/logs/20230416/8514884452928_276-693038-3125989.log,
processId=0, appIds=null, event=RUNNING, varPool=null, channel=[id:
0x186d1c86, L:/172.18.224.7:5678 - R:/172.18.224.10:59176],
processInstanceId=693038)
[INFO] 2023-04-16 22:34:00.772 +0800
org.apache.dolphinscheduler.server.master.processor.queue.TaskExecuteRunnable:[56]
- [WorkflowInstance-693038][TaskInstance-3125990] - Handle task event begin:
TaskEvent(taskInstanceId=3125990, workerAddress=172.18.224.10:1234, state=null,
startTime=null, endTime=null, executePath=null, logPath=null, processId=0,
appIds=null, event=DISPATCH, varPool=null, channel=null,
processInstanceId=693038)
[INFO] 2023-04-16 22:34:00.773 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[287]
- [WorkflowInstance-693038][TaskInstance-3125987] - Begin to handle state
event, TaskStateEvent(processInstanceId=693038, taskInstanceId=3125987,
taskCode=0, status=TaskExecutionStatus{code=1, desc='running'},
type=TASK_STATE_CHANGE, key=null, channel=null, context=null)
[INFO] 2023-04-16 22:34:00.773 +0800
org.apache.dolphinscheduler.server.master.event.TaskStateEventHandler:[57] -
[WorkflowInstance-693038][TaskInstance-3125987] - Handle task instance state
event, the current task instance state TaskExecutionStatus{code=1,
desc='running'} will be changed to TaskExecutionStatus{code=1, desc='running'}
[INFO] 2023-04-16 22:34:00.773 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[287]
- [WorkflowInstance-693038][TaskInstance-3125988] - Begin to handle state
event, TaskStateEvent(processInstanceId=693038, taskInstanceId=3125988,
taskCode=0, status=TaskExecutionStatus{code=1, desc='running'},
type=TASK_STATE_CHANGE, key=null, channel=null, context=null)
[INFO] 2023-04-16 22:34:00.773 +0800
org.apache.dolphinscheduler.server.master.event.TaskStateEventHandler:[57] -
[WorkflowInstance-693038][TaskInstance-3125988] - Handle task instance state
event, the current task instance state TaskExecutionStatus{code=1,
desc='running'} will be changed to TaskExecutionStatus{code=1, desc='running'}
[INFO] 2023-04-16 22:34:00.773 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[287]
- [WorkflowInstance-693038][TaskInstance-3125989] - Begin to handle state
event, TaskStateEvent(processInstanceId=693038, taskInstanceId=3125989,
taskCode=0, status=TaskExecutionStatus{code=1, desc='running'},
type=TASK_STATE_CHANGE, key=null, channel=null, context=null)
[INFO] 2023-04-16 22:34:00.773 +0800
org.apache.dolphinscheduler.server.master.event.TaskStateEventHandler:[57] -
[WorkflowInstance-693038][TaskInstance-3125989] - Handle task instance state
event, the current task instance state TaskExecutionStatus{code=1,
desc='running'} will be changed to TaskExecutionStatus{code=1, desc='running'}
[INFO] 2023-04-16 22:34:00.775 +0800
org.apache.dolphinscheduler.server.master.processor.queue.TaskExecuteRunnable:[59]
- [WorkflowInstance-693038][TaskInstance-3125990] - Handle task event
finished: TaskEvent(taskInstanceId=3125990, workerAddress=172.18.224.10:1234,
state=null, startTime=null, endTime=null, executePath=null, logPath=null,
processId=0, appIds=null, event=DISPATCH, varPool=null, channel=null,
processInstanceId=693038)
[INFO] 2023-04-16 22:34:00.775 +0800
org.apache.dolphinscheduler.server.master.processor.queue.TaskExecuteRunnable:[56]
- [WorkflowInstance-693038][TaskInstance-3125990] - Handle task event begin:
TaskEvent(taskInstanceId=3125990, workerAddress=172.18.224.10:1234,
state=TaskExecutionStatus{code=1, desc='running'}, startTime=Sun Apr 16
22:34:00 CST 2023, endTime=null, executePath=null,
logPath=/tol/app/dolphinscheduler/worker-server/logs/20230416/8514884452928_276-693038-3125990.log,
processId=0, appIds=null, event=RUNNING, varPool=null, channel=[id:
0x186d1c86, L:/172.18.224.7:5678 - R:/172.18.224.10:59176],
processInstanceId=693038)
[INFO] 2023-04-16 22:34:00.778 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteThreadPool:[97]
- [WorkflowInstance-693038][TaskInstance-3125990] - Submit state event success,
stateEvent: TaskStateEvent(processInstanceId=693038, taskInstanceId=3125990,
taskCode=0, status=TaskExecutionStatus{code=1, desc='running'},
type=TASK_STATE_CHANGE, key=null, channel=null, context=null)
[INFO] 2023-04-16 22:34:00.778 +0800
org.apache.dolphinscheduler.server.master.processor.queue.TaskExecuteRunnable:[59]
- [WorkflowInstance-693038][TaskInstance-3125990] - Handle task event
finished: TaskEvent(taskInstanceId=3125990, workerAddress=172.18.224.10:1234,
state=TaskExecutionStatus{code=1, desc='running'}, startTime=Sun Apr 16
22:34:00 CST 2023, endTime=null, executePath=null,
logPath=/tol/app/dolphinscheduler/worker-server/logs/20230416/8514884452928_276-693038-3125990.log,
processId=0, appIds=null, event=RUNNING, varPool=null, channel=[id:
0x186d1c86, L:/172.18.224.7:5678 - R:/172.18.224.10:59176],
processInstanceId=693038)
[INFO] 2023-04-16 22:34:00.778 +0800
org.apache.dolphinscheduler.server.master.processor.queue.TaskExecuteRunnable:[56]
- [WorkflowInstance-693038][TaskInstance-3125991] - Handle task event begin:
TaskEvent(taskInstanceId=3125991, workerAddress=172.18.224.135:1234,
state=null, startTime=null, endTime=null, executePath=null, logPath=null,
processId=0, appIds=null, event=DISPATCH, varPool=null, channel=null,
processInstanceId=693038)
[INFO] 2023-04-16 22:34:00.780 +0800
org.apache.dolphinscheduler.server.master.processor.queue.TaskExecuteRunnable:[59]
- [WorkflowInstance-693038][TaskInstance-3125991] - Handle task event
finished: TaskEvent(taskInstanceId=3125991, workerAddress=172.18.224.135:1234,
state=null, startTime=null, endTime=null, executePath=null, logPath=null,
processId=0, appIds=null, event=DISPATCH, varPool=null, channel=null,
processInstanceId=693038)
[INFO] 2023-04-16 22:34:00.780 +0800
org.apache.dolphinscheduler.server.master.processor.queue.TaskExecuteRunnable:[56]
- [WorkflowInstance-693038][TaskInstance-3125991] - Handle task event begin:
TaskEvent(taskInstanceId=3125991, workerAddress=172.18.224.135:1234,
state=TaskExecutionStatus{code=1, desc='running'}, startTime=Sun Apr 16
22:34:00 CST 2023, endTime=null, executePath=null,
logPath=/tol/app/dolphinscheduler/worker-server/logs/20230416/8514884452928_276-693038-3125991.log,
processId=0, appIds=null, event=RUNNING, varPool=null, channel=[id:
0x18f833dd, L:/172.18.224.7:5678 - R:/172.18.224.135:45382],
processInstanceId=693038)
[INFO] 2023-04-16 22:34:00.783 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteThreadPool:[97]
- [WorkflowInstance-693038][TaskInstance-3125991] - Submit state event success,
stateEvent: TaskStateEvent(processInstanceId=693038, taskInstanceId=3125991,
taskCode=0, status=TaskExecutionStatus{code=1, desc='running'},
type=TASK_STATE_CHANGE, key=null, channel=null, context=null)
[INFO] 2023-04-16 22:34:00.783 +0800
org.apache.dolphinscheduler.server.master.processor.queue.TaskExecuteRunnable:[59]
- [WorkflowInstance-693038][TaskInstance-3125991] - Handle task event
finished: TaskEvent(taskInstanceId=3125991, workerAddress=172.18.224.135:1234,
state=TaskExecutionStatus{code=1, desc='running'}, startTime=Sun Apr 16
22:34:00 CST 2023, endTime=null, executePath=null,
logPath=/tol/app/dolphinscheduler/worker-server/logs/20230416/8514884452928_276-693038-3125991.log,
processId=0, appIds=null, event=RUNNING, varPool=null, channel=[id:
0x18f833dd, L:/172.18.224.7:5678 - R:/172.18.224.135:45382],
processInstanceId=693038)
[INFO] 2023-04-16 22:34:00.783 +0800
org.apache.dolphinscheduler.server.master.processor.queue.TaskExecuteThreadPool:[123]
- [WorkflowInstance-0][TaskInstance-0] - [WorkflowInstance-693038] persist
events succeeded
[INFO] 2023-04-16 22:34:00.873 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[287]
- [WorkflowInstance-693038][TaskInstance-3125990] - Begin to handle state
event, TaskStateEvent(processInstanceId=693038, taskInstanceId=3125990,
taskCode=0, status=TaskExecutionStatus{code=1, desc='running'},
type=TASK_STATE_CHANGE, key=null, channel=null, context=null)
[INFO] 2023-04-16 22:34:00.873 +0800
org.apache.dolphinscheduler.server.master.event.TaskStateEventHandler:[57] -
[WorkflowInstance-693038][TaskInstance-3125990] - Handle task instance state
event, the current task instance state TaskExecutionStatus{code=1,
desc='running'} will be changed to TaskExecutionStatus{code=1, desc='running'}
[INFO] 2023-04-16 22:34:00.874 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[287]
- [WorkflowInstance-693038][TaskInstance-3125991] - Begin to handle state
event, TaskStateEvent(processInstanceId=693038, taskInstanceId=3125991,
taskCode=0, status=TaskExecutionStatus{code=1, desc='running'},
type=TASK_STATE_CHANGE, key=null, channel=null, context=null)
[INFO] 2023-04-16 22:34:00.874 +0800
org.apache.dolphinscheduler.server.master.event.TaskStateEventHandler:[57] -
[WorkflowInstance-693038][TaskInstance-3125991] - Handle task instance state
event, the current task instance state TaskExecutionStatus{code=1,
desc='running'} will be changed to TaskExecutionStatus{code=1, desc='running'}
[INFO] 2023-04-16 22:34:14.089 +0800
org.apache.dolphinscheduler.server.master.processor.TaskExecuteResponseProcessor:[68]
- [WorkflowInstance-693038][TaskInstance-3125988] - Received task execute
result, event: TaskEvent(taskInstanceId=3125988,
workerAddress=172.18.224.135:1234, state=TaskExecutionStatus{code=7,
desc='success'}, startTime=Sun Apr 16 22:34:00 CST 2023, endTime=Sun Apr 16
22:34:14 CST 2023,
executePath=/tmp/dolphinscheduler/exec/process/dolphinscheduler/8048068287296/8514884452928_276/693038/3125988,
logPath=/tol/app/dolphinscheduler/worker-server/logs/20230416/8514884452928_276-693038-3125988.log,
processId=18723, appIds=null, event=RESULT, varPool=[], channel=[id:
0x18f833dd, L:/172.18.224.7:5678 - R:/172.18.224.135:45382],
processInstanceId=693038)
[INFO] 2023-04-16 22:34:14.089 +0800
org.apache.dolphinscheduler.server.master.processor.TaskExecuteResponseProcessor:[68]
- [WorkflowInstance-693038][TaskInstance-3125991] - Received task execute
result, event: TaskEvent(taskInstanceId=3125991,
workerAddress=172.18.224.135:1234, state=TaskExecutionStatus{code=7,
desc='success'}, startTime=Sun Apr 16 22:34:00 CST 2023, endTime=Sun Apr 16
22:34:14 CST 2023,
executePath=/tmp/dolphinscheduler/exec/process/dolphinscheduler/8048068287296/8514884452928_276/693038/3125991,
logPath=/tol/app/dolphinscheduler/worker-server/logs/20230416/8514884452928_276-693038-3125991.log,
processId=18733, appIds=null, event=RESULT, varPool=[], channel=[id:
0x18f833dd, L:/172.18.224.7:5678 - R:/172.18.224.135:45382],
processInstanceId=693038)
[INFO] 2023-04-16 22:34:14.164 +0800
org.apache.dolphinscheduler.server.master.processor.TaskExecuteResponseProcessor:[68]
- [WorkflowInstance-693038][TaskInstance-3125990] - Received task execute
result, event: TaskEvent(taskInstanceId=3125990,
workerAddress=172.18.224.10:1234, state=TaskExecutionStatus{code=7,
desc='success'}, startTime=Sun Apr 16 22:34:00 CST 2023, endTime=Sun Apr 16
22:34:14 CST 2023,
executePath=/tmp/dolphinscheduler/exec/process/dolphinscheduler/8048068287296/8514884452928_276/693038/3125990,
logPath=/tol/app/dolphinscheduler/worker-server/logs/20230416/8514884452928_276-693038-3125990.log,
processId=5877, appIds=null, event=RESULT, varPool=[], channel=[id:
0x186d1c86, L:/172.18.224.7:5678 - R:/172.18.224.10:59176],
processInstanceId=693038)
[INFO] 2023-04-16 22:34:14.170 +0800
org.apache.dolphinscheduler.server.master.processor.TaskExecuteResponseProcessor:[68]
- [WorkflowInstance-693038][TaskInstance-3125989] - Received task execute
result, event: TaskEvent(taskInstanceId=3125989,
workerAddress=172.18.224.10:1234, state=TaskExecutionStatus{code=7,
desc='success'}, startTime=Sun Apr 16 22:34:00 CST 2023, endTime=Sun Apr 16
22:34:14 CST 2023,
executePath=/tmp/dolphinscheduler/exec/process/dolphinscheduler/8048068287296/8514884452928_276/693038/3125989,
logPath=/tol/app/dolphinscheduler/worker-server/logs/20230416/8514884452928_276-693038-3125989.log,
processId=5868, appIds=null, event=RESULT, varPool=[], channel=[id:
0x186d1c86, L:/172.18.224.7:5678 - R:/172.18.224.10:59176],
processInstanceId=693038)
[INFO] 2023-04-16 22:34:14.230 +0800
org.apache.dolphinscheduler.server.master.processor.TaskExecuteResponseProcessor:[68]
- [WorkflowInstance-693038][TaskInstance-3125987] - Received task execute
result, event: TaskEvent(taskInstanceId=3125987,
workerAddress=172.18.224.10:1234, state=TaskExecutionStatus{code=7,
desc='success'}, startTime=Sun Apr 16 22:34:00 CST 2023, endTime=Sun Apr 16
22:34:14 CST 2023,
executePath=/tmp/dolphinscheduler/exec/process/dolphinscheduler/8048068287296/8514884452928_276/693038/3125987,
logPath=/tol/app/dolphinscheduler/worker-server/logs/20230416/8514884452928_276-693038-3125987.log,
processId=5864, appIds=null, event=RESULT, varPool=[], channel=[id:
0x186d1c86, L:/172.18.224.7:5678 - R:/172.18.224.10:59176],
processInstanceId=693038)
[INFO] 2023-04-16 22:34:14.777 +0800
org.apache.dolphinscheduler.server.master.processor.queue.TaskExecuteRunnable:[56]
- [WorkflowInstance-693038][TaskInstance-3125988] - Handle task event begin:
TaskEvent(taskInstanceId=3125988, workerAddress=172.18.224.135:1234,
state=TaskExecutionStatus{code=7, desc='success'}, startTime=Sun Apr 16
22:34:00 CST 2023, endTime=Sun Apr 16 22:34:14 CST 2023,
executePath=/tmp/dolphinscheduler/exec/process/dolphinscheduler/8048068287296/8514884452928_276/693038/3125988,
logPath=/tol/app/dolphinscheduler/worker-server/logs/20230416/8514884452928_276-693038-3125988.log,
processId=18723, appIds=null, event=RESULT, varPool=[], channel=[id:
0x18f833dd, L:/172.18.224.7:5678 - R:/172.18.224.135:45382],
processInstanceId=693038)
[INFO] 2023-04-16 22:34:14.781 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteThreadPool:[97]
- [WorkflowInstance-693038][TaskInstance-3125988] - Submit state event success,
stateEvent: TaskStateEvent(processInstanceId=693038, taskInstanceId=3125988,
taskCode=0, status=TaskExecutionStatus{code=7, desc='success'},
type=TASK_STATE_CHANGE, key=null, channel=null, context=null)
[INFO] 2023-04-16 22:34:14.781 +0800
org.apache.dolphinscheduler.server.master.processor.queue.TaskExecuteRunnable:[59]
- [WorkflowInstance-693038][TaskInstance-3125988] - Handle task event
finished: TaskEvent(taskInstanceId=3125988, workerAddress=172.18.224.135:1234,
state=TaskExecutionStatus{code=7, desc='success'}, startTime=Sun Apr 16
22:34:00 CST 2023, endTime=Sun Apr 16 22:34:14 CST 2023,
executePath=/tmp/dolphinscheduler/exec/process/dolphinscheduler/8048068287296/8514884452928_276/693038/3125988,
logPath=/tol/app/dolphinscheduler/worker-server/logs/20230416/8514884452928_276-693038-3125988.log,
processId=18723, appIds=null, event=RESULT, varPool=[], channel=[id:
0x18f833dd, L:/172.18.224.7:5678 - R:/172.18.224.135:45382],
processInstanceId=693038)
[INFO] 2023-04-16 22:34:14.781 +0800
org.apache.dolphinscheduler.server.master.processor.queue.TaskExecuteRunnable:[56]
- [WorkflowInstance-693038][TaskInstance-3125991] - Handle task event begin:
TaskEvent(taskInstanceId=3125991, workerAddress=172.18.224.135:1234,
state=TaskExecutionStatus{code=7, desc='success'}, startTime=Sun Apr 16
22:34:00 CST 2023, endTime=Sun Apr 16 22:34:14 CST 2023,
executePath=/tmp/dolphinscheduler/exec/process/dolphinscheduler/8048068287296/8514884452928_276/693038/3125991,
logPath=/tol/app/dolphinscheduler/worker-server/logs/20230416/8514884452928_276-693038-3125991.log,
processId=18733, appIds=null, event=RESULT, varPool=[], channel=[id:
0x18f833dd, L:/172.18.224.7:5678 - R:/172.18.224.135:45382],
processInstanceId=693038)
[INFO] 2023-04-16 22:34:14.784 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteThreadPool:[97]
- [WorkflowInstance-693038][TaskInstance-3125991] - Submit state event success,
stateEvent: TaskStateEvent(processInstanceId=693038, taskInstanceId=3125991,
taskCode=0, status=TaskExecutionStatus{code=7, desc='success'},
type=TASK_STATE_CHANGE, key=null, channel=null, context=null)
[INFO] 2023-04-16 22:34:14.784 +0800
org.apache.dolphinscheduler.server.master.processor.queue.TaskExecuteRunnable:[59]
- [WorkflowInstance-693038][TaskInstance-3125991] - Handle task event
finished: TaskEvent(taskInstanceId=3125991, workerAddress=172.18.224.135:1234,
state=TaskExecutionStatus{code=7, desc='success'}, startTime=Sun Apr 16
22:34:00 CST 2023, endTime=Sun Apr 16 22:34:14 CST 2023,
executePath=/tmp/dolphinscheduler/exec/process/dolphinscheduler/8048068287296/8514884452928_276/693038/3125991,
logPath=/tol/app/dolphinscheduler/worker-server/logs/20230416/8514884452928_276-693038-3125991.log,
processId=18733, appIds=null, event=RESULT, varPool=[], channel=[id:
0x18f833dd, L:/172.18.224.7:5678 - R:/172.18.224.135:45382],
processInstanceId=693038)
[INFO] 2023-04-16 22:34:14.784 +0800
org.apache.dolphinscheduler.server.master.processor.queue.TaskExecuteRunnable:[56]
- [WorkflowInstance-693038][TaskInstance-3125990] - Handle task event begin:
TaskEvent(taskInstanceId=3125990, workerAddress=172.18.224.10:1234,
state=TaskExecutionStatus{code=7, desc='success'}, startTime=Sun Apr 16
22:34:00 CST 2023, endTime=Sun Apr 16 22:34:14 CST 2023,
executePath=/tmp/dolphinscheduler/exec/process/dolphinscheduler/8048068287296/8514884452928_276/693038/3125990,
logPath=/tol/app/dolphinscheduler/worker-server/logs/20230416/8514884452928_276-693038-3125990.log,
processId=5877, appIds=null, event=RESULT, varPool=[], channel=[id:
0x186d1c86, L:/172.18.224.7:5678 - R:/172.18.224.10:59176],
processInstanceId=693038)
[INFO] 2023-04-16 22:34:14.787 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteThreadPool:[97]
- [WorkflowInstance-693038][TaskInstance-3125990] - Submit state event success,
stateEvent: TaskStateEvent(processInstanceId=693038, taskInstanceId=3125990,
taskCode=0, status=TaskExecutionStatus{code=7, desc='success'},
type=TASK_STATE_CHANGE, key=null, channel=null, context=null)
[INFO] 2023-04-16 22:34:14.787 +0800
org.apache.dolphinscheduler.server.master.processor.queue.TaskExecuteRunnable:[59]
- [WorkflowInstance-693038][TaskInstance-3125990] - Handle task event
finished: TaskEvent(taskInstanceId=3125990, workerAddress=172.18.224.10:1234,
state=TaskExecutionStatus{code=7, desc='success'}, startTime=Sun Apr 16
22:34:00 CST 2023, endTime=Sun Apr 16 22:34:14 CST 2023,
executePath=/tmp/dolphinscheduler/exec/process/dolphinscheduler/8048068287296/8514884452928_276/693038/3125990,
logPath=/tol/app/dolphinscheduler/worker-server/logs/20230416/8514884452928_276-693038-3125990.log,
processId=5877, appIds=null, event=RESULT, varPool=[], channel=[id:
0x186d1c86, L:/172.18.224.7:5678 - R:/172.18.224.10:59176],
processInstanceId=693038)
[INFO] 2023-04-16 22:34:14.787 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[287]
- [WorkflowInstance-693038][TaskInstance-3125988] - Begin to handle state
event, TaskStateEvent(processInstanceId=693038, taskInstanceId=3125988,
taskCode=0, status=TaskExecutionStatus{code=7, desc='success'},
type=TASK_STATE_CHANGE, key=null, channel=null, context=null)
[INFO] 2023-04-16 22:34:14.787 +0800
org.apache.dolphinscheduler.server.master.event.TaskStateEventHandler:[57] -
[WorkflowInstance-693038][TaskInstance-3125988] - Handle task instance state
event, the current task instance state TaskExecutionStatus{code=7,
desc='success'} will be changed to TaskExecutionStatus{code=7, desc='success'}
[INFO] 2023-04-16 22:34:14.787 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[385]
- [WorkflowInstance-693038][TaskInstance-3125988] - TaskInstance finished task
code:8879185628736 state:TaskExecutionStatus{code=7, desc='success'}
[INFO] 2023-04-16 22:34:14.787 +0800
org.apache.dolphinscheduler.server.master.processor.queue.TaskExecuteRunnable:[56]
- [WorkflowInstance-693038][TaskInstance-3125989] - Handle task event begin:
TaskEvent(taskInstanceId=3125989, workerAddress=172.18.224.10:1234,
state=TaskExecutionStatus{code=7, desc='success'}, startTime=Sun Apr 16
22:34:00 CST 2023, endTime=Sun Apr 16 22:34:14 CST 2023,
executePath=/tmp/dolphinscheduler/exec/process/dolphinscheduler/8048068287296/8514884452928_276/693038/3125989,
logPath=/tol/app/dolphinscheduler/worker-server/logs/20230416/8514884452928_276-693038-3125989.log,
processId=5868, appIds=null, event=RESULT, varPool=[], channel=[id:
0x186d1c86, L:/172.18.224.7:5678 - R:/172.18.224.10:59176],
processInstanceId=693038)
[INFO] 2023-04-16 22:34:14.787 +0800
org.apache.dolphinscheduler.server.master.runner.StateWheelExecuteThread:[195]
- [WorkflowInstance-693038][TaskInstance-3125988] - remove task instance from
timeout check list
[INFO] 2023-04-16 22:34:14.787 +0800
org.apache.dolphinscheduler.server.master.runner.StateWheelExecuteThread:[218]
- [WorkflowInstance-693038][TaskInstance-3125988] - remove task instance from
retry check list
[INFO] 2023-04-16 22:34:14.787 +0800
org.apache.dolphinscheduler.server.master.runner.StateWheelExecuteThread:[237]
- [WorkflowInstance-693038][TaskInstance-3125988] - Removed task instance from
state check list
[INFO] 2023-04-16 22:34:14.791 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[1581]
- [WorkflowInstance-693038][TaskInstance-3125988] - The workflowInstance has
task running, the workflowInstance status is WorkflowExecutionStatus{code=1,
desc='running'}
[INFO] 2023-04-16 22:34:14.791 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[1672]
- [WorkflowInstance-693038][TaskInstance-3125988] - There is no need to update
the workflow instance state, origin state: WorkflowExecutionStatus{code=1,
desc='running'}, target state: WorkflowExecutionStatus{code=1, desc='running'}
[INFO] 2023-04-16 22:34:14.791 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[422]
- [WorkflowInstance-693038][TaskInstance-3125988] - TaskInstance finished will
try to update the workflow instance state, task code:8879185628736
state:TaskExecutionStatus{code=7, desc='success'}
[INFO] 2023-04-16 22:34:14.791 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[1581]
- [WorkflowInstance-693038][TaskInstance-3125988] - The workflowInstance has
task running, the workflowInstance status is WorkflowExecutionStatus{code=1,
desc='running'}
[INFO] 2023-04-16 22:34:14.791 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[1672]
- [WorkflowInstance-693038][TaskInstance-3125988] - There is no need to update
the workflow instance state, origin state: WorkflowExecutionStatus{code=1,
desc='running'}, target state: WorkflowExecutionStatus{code=1, desc='running'}
[INFO] 2023-04-16 22:34:14.791 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[287]
- [WorkflowInstance-693038][TaskInstance-3125991] - Begin to handle state
event, TaskStateEvent(processInstanceId=693038, taskInstanceId=3125991,
taskCode=0, status=TaskExecutionStatus{code=7, desc='success'},
type=TASK_STATE_CHANGE, key=null, channel=null, context=null)
[INFO] 2023-04-16 22:34:14.791 +0800
org.apache.dolphinscheduler.server.master.event.TaskStateEventHandler:[57] -
[WorkflowInstance-693038][TaskInstance-3125991] - Handle task instance state
event, the current task instance state TaskExecutionStatus{code=7,
desc='success'} will be changed to TaskExecutionStatus{code=7, desc='success'}
[INFO] 2023-04-16 22:34:14.791 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[385]
- [WorkflowInstance-693038][TaskInstance-3125991] - TaskInstance finished task
code:8879185631680 state:TaskExecutionStatus{code=7, desc='success'}
[INFO] 2023-04-16 22:34:14.791 +0800
org.apache.dolphinscheduler.server.master.runner.StateWheelExecuteThread:[195]
- [WorkflowInstance-693038][TaskInstance-3125991] - remove task instance from
timeout check list
[INFO] 2023-04-16 22:34:14.791 +0800
org.apache.dolphinscheduler.server.master.runner.StateWheelExecuteThread:[218]
- [WorkflowInstance-693038][TaskInstance-3125991] - remove task instance from
retry check list
[INFO] 2023-04-16 22:34:14.791 +0800
org.apache.dolphinscheduler.server.master.runner.StateWheelExecuteThread:[237]
- [WorkflowInstance-693038][TaskInstance-3125991] - Removed task instance from
state check list
[INFO] 2023-04-16 22:34:14.793 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteThreadPool:[97]
- [WorkflowInstance-693038][TaskInstance-3125989] - Submit state event success,
stateEvent: TaskStateEvent(processInstanceId=693038, taskInstanceId=3125989,
taskCode=0, status=TaskExecutionStatus{code=7, desc='success'},
type=TASK_STATE_CHANGE, key=null, channel=null, context=null)
[INFO] 2023-04-16 22:34:14.793 +0800
org.apache.dolphinscheduler.server.master.processor.queue.TaskExecuteRunnable:[59]
- [WorkflowInstance-693038][TaskInstance-3125989] - Handle task event
finished: TaskEvent(taskInstanceId=3125989, workerAddress=172.18.224.10:1234,
state=TaskExecutionStatus{code=7, desc='success'}, startTime=Sun Apr 16
22:34:00 CST 2023, endTime=Sun Apr 16 22:34:14 CST 2023,
executePath=/tmp/dolphinscheduler/exec/process/dolphinscheduler/8048068287296/8514884452928_276/693038/3125989,
logPath=/tol/app/dolphinscheduler/worker-server/logs/20230416/8514884452928_276-693038-3125989.log,
processId=5868, appIds=null, event=RESULT, varPool=[], channel=[id:
0x186d1c86, L:/172.18.224.7:5678 - R:/172.18.224.10:59176],
processInstanceId=693038)
[INFO] 2023-04-16 22:34:14.793 +0800
org.apache.dolphinscheduler.server.master.processor.queue.TaskExecuteRunnable:[56]
- [WorkflowInstance-693038][TaskInstance-3125987] - Handle task event begin:
TaskEvent(taskInstanceId=3125987, workerAddress=172.18.224.10:1234,
state=TaskExecutionStatus{code=7, desc='success'}, startTime=Sun Apr 16
22:34:00 CST 2023, endTime=Sun Apr 16 22:34:14 CST 2023,
executePath=/tmp/dolphinscheduler/exec/process/dolphinscheduler/8048068287296/8514884452928_276/693038/3125987,
logPath=/tol/app/dolphinscheduler/worker-server/logs/20230416/8514884452928_276-693038-3125987.log,
processId=5864, appIds=null, event=RESULT, varPool=[], channel=[id:
0x186d1c86, L:/172.18.224.7:5678 - R:/172.18.224.10:59176],
processInstanceId=693038)
[INFO] 2023-04-16 22:34:14.794 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[1581]
- [WorkflowInstance-693038][TaskInstance-3125991] - The workflowInstance has
task running, the workflowInstance status is WorkflowExecutionStatus{code=1,
desc='running'}
[INFO] 2023-04-16 22:34:14.794 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[1672]
- [WorkflowInstance-693038][TaskInstance-3125991] - There is no need to update
the workflow instance state, origin state: WorkflowExecutionStatus{code=1,
desc='running'}, target state: WorkflowExecutionStatus{code=1, desc='running'}
[INFO] 2023-04-16 22:34:14.794 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[422]
- [WorkflowInstance-693038][TaskInstance-3125991] - TaskInstance finished will
try to update the workflow instance state, task code:8879185631680
state:TaskExecutionStatus{code=7, desc='success'}
[INFO] 2023-04-16 22:34:14.794 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[1581]
- [WorkflowInstance-693038][TaskInstance-3125991] - The workflowInstance has
task running, the workflowInstance status is WorkflowExecutionStatus{code=1,
desc='running'}
[INFO] 2023-04-16 22:34:14.794 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[1672]
- [WorkflowInstance-693038][TaskInstance-3125991] - There is no need to update
the workflow instance state, origin state: WorkflowExecutionStatus{code=1,
desc='running'}, target state: WorkflowExecutionStatus{code=1, desc='running'}
[INFO] 2023-04-16 22:34:14.794 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[287]
- [WorkflowInstance-693038][TaskInstance-3125990] - Begin to handle state
event, TaskStateEvent(processInstanceId=693038, taskInstanceId=3125990,
taskCode=0, status=TaskExecutionStatus{code=7, desc='success'},
type=TASK_STATE_CHANGE, key=null, channel=null, context=null)
[INFO] 2023-04-16 22:34:14.794 +0800
org.apache.dolphinscheduler.server.master.event.TaskStateEventHandler:[57] -
[WorkflowInstance-693038][TaskInstance-3125990] - Handle task instance state
event, the current task instance state TaskExecutionStatus{code=7,
desc='success'} will be changed to TaskExecutionStatus{code=7, desc='success'}
[INFO] 2023-04-16 22:34:14.794 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[385]
- [WorkflowInstance-693038][TaskInstance-3125990] - TaskInstance finished task
code:8879185634624 state:TaskExecutionStatus{code=7, desc='success'}
[INFO] 2023-04-16 22:34:14.794 +0800
org.apache.dolphinscheduler.server.master.runner.StateWheelExecuteThread:[195]
- [WorkflowInstance-693038][TaskInstance-3125990] - remove task instance from
timeout check list
[INFO] 2023-04-16 22:34:14.794 +0800
org.apache.dolphinscheduler.server.master.runner.StateWheelExecuteThread:[218]
- [WorkflowInstance-693038][TaskInstance-3125990] - remove task instance from
retry check list
[INFO] 2023-04-16 22:34:14.794 +0800
org.apache.dolphinscheduler.server.master.runner.StateWheelExecuteThread:[237]
- [WorkflowInstance-693038][TaskInstance-3125990] - Removed task instance from
state check list
[INFO] 2023-04-16 22:34:14.796 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteThreadPool:[97]
- [WorkflowInstance-693038][TaskInstance-3125987] - Submit state event success,
stateEvent: TaskStateEvent(processInstanceId=693038, taskInstanceId=3125987,
taskCode=0, status=TaskExecutionStatus{code=7, desc='success'},
type=TASK_STATE_CHANGE, key=null, channel=null, context=null)
[INFO] 2023-04-16 22:34:14.796 +0800
org.apache.dolphinscheduler.server.master.processor.queue.TaskExecuteRunnable:[59]
- [WorkflowInstance-693038][TaskInstance-3125987] - Handle task event
finished: TaskEvent(taskInstanceId=3125987, workerAddress=172.18.224.10:1234,
state=TaskExecutionStatus{code=7, desc='success'}, startTime=Sun Apr 16
22:34:00 CST 2023, endTime=Sun Apr 16 22:34:14 CST 2023,
executePath=/tmp/dolphinscheduler/exec/process/dolphinscheduler/8048068287296/8514884452928_276/693038/3125987,
logPath=/tol/app/dolphinscheduler/worker-server/logs/20230416/8514884452928_276-693038-3125987.log,
processId=5864, appIds=null, event=RESULT, varPool=[], channel=[id:
0x186d1c86, L:/172.18.224.7:5678 - R:/172.18.224.10:59176],
processInstanceId=693038)
[INFO] 2023-04-16 22:34:14.796 +0800
org.apache.dolphinscheduler.server.master.processor.queue.TaskExecuteThreadPool:[123]
- [WorkflowInstance-0][TaskInstance-0] - [WorkflowInstance-693038] persist
events succeeded
[INFO] 2023-04-16 22:34:14.796 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[1581]
- [WorkflowInstance-693038][TaskInstance-3125990] - The workflowInstance has
task running, the workflowInstance status is WorkflowExecutionStatus{code=1,
desc='running'}
[INFO] 2023-04-16 22:34:14.796 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[1672]
- [WorkflowInstance-693038][TaskInstance-3125990] - There is no need to update
the workflow instance state, origin state: WorkflowExecutionStatus{code=1,
desc='running'}, target state: WorkflowExecutionStatus{code=1, desc='running'}
[INFO] 2023-04-16 22:34:14.796 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[422]
- [WorkflowInstance-693038][TaskInstance-3125990] - TaskInstance finished will
try to update the workflow instance state, task code:8879185634624
state:TaskExecutionStatus{code=7, desc='success'}
[INFO] 2023-04-16 22:34:14.796 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[1581]
- [WorkflowInstance-693038][TaskInstance-3125990] - The workflowInstance has
task running, the workflowInstance status is WorkflowExecutionStatus{code=1,
desc='running'}
[INFO] 2023-04-16 22:34:14.796 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[1672]
- [WorkflowInstance-693038][TaskInstance-3125990] - There is no need to update
the workflow instance state, origin state: WorkflowExecutionStatus{code=1,
desc='running'}, target state: WorkflowExecutionStatus{code=1, desc='running'}
[INFO] 2023-04-16 22:34:14.796 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[287]
- [WorkflowInstance-693038][TaskInstance-3125989] - Begin to handle state
event, TaskStateEvent(processInstanceId=693038, taskInstanceId=3125989,
taskCode=0, status=TaskExecutionStatus{code=7, desc='success'},
type=TASK_STATE_CHANGE, key=null, channel=null, context=null)
[INFO] 2023-04-16 22:34:14.796 +0800
org.apache.dolphinscheduler.server.master.event.TaskStateEventHandler:[57] -
[WorkflowInstance-693038][TaskInstance-3125989] - Handle task instance state
event, the current task instance state TaskExecutionStatus{code=7,
desc='success'} will be changed to TaskExecutionStatus{code=7, desc='success'}
[INFO] 2023-04-16 22:34:14.797 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[385]
- [WorkflowInstance-693038][TaskInstance-3125989] - TaskInstance finished task
code:8879185625920 state:TaskExecutionStatus{code=7, desc='success'}
[INFO] 2023-04-16 22:34:14.797 +0800
org.apache.dolphinscheduler.server.master.runner.StateWheelExecuteThread:[195]
- [WorkflowInstance-693038][TaskInstance-3125989] - remove task instance from
timeout check list
[INFO] 2023-04-16 22:34:14.797 +0800
org.apache.dolphinscheduler.server.master.runner.StateWheelExecuteThread:[218]
- [WorkflowInstance-693038][TaskInstance-3125989] - remove task instance from
retry check list
[INFO] 2023-04-16 22:34:14.797 +0800
org.apache.dolphinscheduler.server.master.runner.StateWheelExecuteThread:[237]
- [WorkflowInstance-693038][TaskInstance-3125989] - Removed task instance from
state check list
[INFO] 2023-04-16 22:34:14.799 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[1581]
- [WorkflowInstance-693038][TaskInstance-3125989] - The workflowInstance has
task running, the workflowInstance status is WorkflowExecutionStatus{code=1,
desc='running'}
[INFO] 2023-04-16 22:34:14.799 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[1672]
- [WorkflowInstance-693038][TaskInstance-3125989] - There is no need to update
the workflow instance state, origin state: WorkflowExecutionStatus{code=1,
desc='running'}, target state: WorkflowExecutionStatus{code=1, desc='running'}
[INFO] 2023-04-16 22:34:14.799 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[422]
- [WorkflowInstance-693038][TaskInstance-3125989] - TaskInstance finished will
try to update the workflow instance state, task code:8879185625920
state:TaskExecutionStatus{code=7, desc='success'}
[INFO] 2023-04-16 22:34:14.799 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[1581]
- [WorkflowInstance-693038][TaskInstance-3125989] - The workflowInstance has
task running, the workflowInstance status is WorkflowExecutionStatus{code=1,
desc='running'}
[INFO] 2023-04-16 22:34:14.799 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[1672]
- [WorkflowInstance-693038][TaskInstance-3125989] - There is no need to update
the workflow instance state, origin state: WorkflowExecutionStatus{code=1,
desc='running'}, target state: WorkflowExecutionStatus{code=1, desc='running'}
[INFO] 2023-04-16 22:34:14.799 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[287]
- [WorkflowInstance-693038][TaskInstance-3125987] - Begin to handle state
event, TaskStateEvent(processInstanceId=693038, taskInstanceId=3125987,
taskCode=0, status=TaskExecutionStatus{code=7, desc='success'},
type=TASK_STATE_CHANGE, key=null, channel=null, context=null)
[INFO] 2023-04-16 22:34:14.799 +0800
org.apache.dolphinscheduler.server.master.event.TaskStateEventHandler:[57] -
[WorkflowInstance-693038][TaskInstance-3125987] - Handle task instance state
event, the current task instance state TaskExecutionStatus{code=7,
desc='success'} will be changed to TaskExecutionStatus{code=7, desc='success'}
[INFO] 2023-04-16 22:34:14.799 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[385]
- [WorkflowInstance-693038][TaskInstance-3125987] - TaskInstance finished task
code:8879185622720 state:TaskExecutionStatus{code=7, desc='success'}
[INFO] 2023-04-16 22:34:14.799 +0800
org.apache.dolphinscheduler.server.master.runner.StateWheelExecuteThread:[195]
- [WorkflowInstance-693038][TaskInstance-3125987] - remove task instance from
timeout check list
[INFO] 2023-04-16 22:34:14.799 +0800
org.apache.dolphinscheduler.server.master.runner.StateWheelExecuteThread:[218]
- [WorkflowInstance-693038][TaskInstance-3125987] - remove task instance from
retry check list
[INFO] 2023-04-16 22:34:14.799 +0800
org.apache.dolphinscheduler.server.master.runner.StateWheelExecuteThread:[237]
- [WorkflowInstance-693038][TaskInstance-3125987] - Removed task instance from
state check list
[INFO] 2023-04-16 22:34:14.801 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[1512]
- [WorkflowInstance-693038][TaskInstance-3125987] - The current process has
failed task, the current process failed
[INFO] 2023-04-16 22:34:14.801 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[1615]
- [WorkflowInstance-693038][TaskInstance-3125987] - The workflowInstance is
failed, the workflow status is WorkflowExecutionStatus{code=6, desc='failure'}
[INFO] 2023-04-16 22:34:14.801 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[1659]
- [WorkflowInstance-693038][TaskInstance-3125987] - Update workflowInstance
states, origin state: WorkflowExecutionStatus{code=1, desc='running'}, target
state: WorkflowExecutionStatus{code=6, desc='failure'}
[INFO] 2023-04-16 22:34:14.801 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[1689]
- [WorkflowInstance-693038][TaskInstance-3125987] - Begin to update workflow
instance state , state will change from WorkflowExecutionStatus{code=1,
desc='running'} to WorkflowExecutionStatus{code=6, desc='failure'}
[INFO] 2023-04-16 22:34:14.804 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[422]
- [WorkflowInstance-693038][TaskInstance-3125987] - TaskInstance finished will
try to update the workflow instance state, task code:8879185622720
state:TaskExecutionStatus{code=7, desc='success'}
[INFO] 2023-04-16 22:34:14.804 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[1512]
- [WorkflowInstance-693038][TaskInstance-3125987] - The current process has
failed task, the current process failed
[INFO] 2023-04-16 22:34:14.804 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[1615]
- [WorkflowInstance-693038][TaskInstance-3125987] - The workflowInstance is
failed, the workflow status is WorkflowExecutionStatus{code=6, desc='failure'}
[INFO] 2023-04-16 22:34:14.804 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[1672]
- [WorkflowInstance-693038][TaskInstance-3125987] - There is no need to update
the workflow instance state, origin state: WorkflowExecutionStatus{code=6,
desc='failure'}, target state: WorkflowExecutionStatus{code=6, desc='failure'}
[INFO] 2023-04-16 22:34:14.804 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteRunnable:[287]
- [WorkflowInstance-693038][TaskInstance-null] - Begin to handle state event,
WorkflowStateEvent(processInstanceId=693038, taskInstanceId=null,
status=WorkflowExecutionStatus{code=6, desc='failure'},
type=PROCESS_STATE_CHANGE, key=null, channel=null, context=null)
[INFO] 2023-04-16 22:34:14.804 +0800
org.apache.dolphinscheduler.server.master.event.WorkflowStateEventHandler:[42]
- [WorkflowInstance-693038][TaskInstance-null] - Handle workflow instance state
event, the current workflow instance state WorkflowExecutionStatus{code=6,
desc='failure'} will be changed to WorkflowExecutionStatus{code=6,
desc='failure'}
[INFO] 2023-04-16 22:34:14.807 +0800
org.apache.dolphinscheduler.service.alert.ProcessAlertManager:[121] -
[WorkflowInstance-693038][TaskInstance-null] -
admin:processDefinition:ProcessDefinition(id=2985, code=8514884452928,
name=dfzx_1min_online, version=276, releaseState=ONLINE,
projectCode=8048068287296, description=,
globalParams=[{"prop":"day_2ago_ymd","direct":"IN","type":"VARCHAR","value":"$[yyyyMMdd-2]"},{"prop":"day_1hourago_ymd","direct":"IN","type":"VARCHAR","value":"$[yyyyMMdd-1/24]"},{"prop":"dws","direct":"IN","type":"VARCHAR","value":"dfzx_dws"},{"prop":"day_ymdh","direct":"IN","type":"VARCHAR","value":"$[yyyyMMddHH]"},{"prop":"day_1ago","direct":"IN","type":"VARCHAR","value":"$[dd-1]"},{"prop":"day_1ago_ymd","direct":"IN","type":"VARCHAR","value":"$[yyyyMMdd-1]"},{"prop":"target_doris_fe_load_url","direct":"IN","type":"VARCHAR","value":"172.28.32.13:8030"},{"prop":"target_url","direct":"IN","type":"VARCHAR","value":"172.28.32.13"},{"prop":"day_1hourago_y_m_d_h","di
rect":"IN","type":"VARCHAR","value":"$[yyyy-MM-dd
HH:00:00-1/24]"},{"prop":"dim","direct":"IN","type":"VARCHAR","value":"dfzx_dim"},{"prop":"day_30ago_y_m_d","direct":"IN","type":"VARCHAR","value":"$[yyyy-MM-dd-30]"},{"prop":"day_60ago_y_m_d","direct":"IN","type":"VARCHAR","value":"$[yyyy-MM-dd-60]"},{"prop":"target_port","direct":"IN","type":"VARCHAR","value":"9030"},{"prop":"day_y_m_d_h_m","direct":"IN","type":"VARCHAR","value":"$[yyyy-MM-dd
HH:mm:00]"},{"prop":"day_1ago_ymd_blackslash","direct":"IN","type":"VARCHAR","value":"$[yyyy/MM/dd-1]"},{"prop":"current","direct":"IN","type":"VARCHAR","value":"$[yyyy-MM-dd
HH:mm:ss]"},{"prop":"databus","direct":"IN","type":"VARCHAR","value":"databus"},{"prop":"day_7ago_ymd_blackslash","direct":"IN","type":"VARCHAR","value":"$[yyyy/MM/dd-7]"},{"prop":"day_1hourago_y_m_d","direct":"IN","type":"VARCHAR","value":"$[yyyy-MM-dd-1/24]"},{"prop":"month_1ago","direct":"IN","type":"VARCHAR","value":"$[MM-1]"},{"prop":"target_username","direct":"IN","
type":"VARCHAR","value":"dw_user"},{"prop":"day_2ago_y_m_d","direct":"IN","type":"VARCHAR","value":"$[yyyy-MM-dd-2]"},{"prop":"day_ymd","direct":"IN","type":"VARCHAR","value":"$[yyyyMMdd]"},{"prop":"day_1hourago_ymdh","direct":"IN","type":"VARCHAR","value":"$[yyyyMMddHH-1/24]"},{"prop":"day_90ago_y_m_d","direct":"IN","type":"VARCHAR","value":"$[yyyy-MM-dd-90]"},{"prop":"target_jdbc_url","direct":"IN","type":"VARCHAR","value":"jdbc:mysql://172.28.32.13:9030?characterEncoding=UTF-8&useUnicode=true&autoReconnect=true&useSSL=false&serverTimezone=Asia/Shanghai"},{"prop":"dwd","direct":"IN","type":"VARCHAR","value":"dfzx_dwd"},{"prop":"day_1ago_y_m_d","direct":"IN","type":"VARCHAR","value":"$[yyyy-MM-dd-1]"},{"prop":"target_database","direct":"IN","type":"VARCHAR","value":"databus"},{"prop":"target_password","direct":"IN","type":"VARCHAR","value":"xdf@1314"},{"prop":"ads","direct":"IN","type":"VARCHAR","value":"dfzx_ads"},{"prop":"day_y_m_d","direct":"IN","type":"VARCHAR","value":"$[yyyy-
MM-dd]"},{"prop":"day_y_m_d_h_end","direct":"IN","type":"VARCHAR","value":"$[yyyy-MM-dd
HH:59:59]"},{"prop":"year_1ago","direct":"IN","type":"VARCHAR","value":"$[yyyy-1]"},{"prop":"day_y_m_d_h","direct":"IN","type":"VARCHAR","value":"$[yyyy-MM-dd
HH:00:00]"},{"prop":"ods","direct":"IN","type":"VARCHAR","value":"dfzx_ods"},{"prop":"day_4next_y_m_d","direct":"IN","type":"VARCHAR","value":"$[yyyy-MM-dd+4]"}],
globalParamList=[Property{prop='day_2ago_ymd', direct=IN, type=VARCHAR,
value='$[yyyyMMdd-2]'}, Property{prop='day_1hourago_ymd', direct=IN,
type=VARCHAR, value='$[yyyyMMdd-1/24]'}, Property{prop='dws', direct=IN,
type=VARCHAR, value='dfzx_dws'}, Property{prop='day_ymdh', direct=IN,
type=VARCHAR, value='$[yyyyMMddHH]'}, Property{prop='day_1ago', direct=IN,
type=VARCHAR, value='$[dd-1]'}, Property{prop='day_1ago_ymd', direct=IN,
type=VARCHAR, value='$[yyyyMMdd-1]'}, Property{prop='target_doris_fe_load_url',
direct=IN, type=VARCHAR, value='172.28.32.13:8030'}, Property{prop='target_
url', direct=IN, type=VARCHAR, value='172.28.32.13'},
Property{prop='day_1hourago_y_m_d_h', direct=IN, type=VARCHAR,
value='$[yyyy-MM-dd HH:00:00-1/24]'}, Property{prop='dim', direct=IN,
type=VARCHAR, value='dfzx_dim'}, Property{prop='day_30ago_y_m_d', direct=IN,
type=VARCHAR, value='$[yyyy-MM-dd-30]'}, Property{prop='day_60ago_y_m_d',
direct=IN, type=VARCHAR, value='$[yyyy-MM-dd-60]'},
Property{prop='target_port', direct=IN, type=VARCHAR, value='9030'},
Property{prop='day_y_m_d_h_m', direct=IN, type=VARCHAR, value='$[yyyy-MM-dd
HH:mm:00]'}, Property{prop='day_1ago_ymd_blackslash', direct=IN, type=VARCHAR,
value='$[yyyy/MM/dd-1]'}, Property{prop='current', direct=IN, type=VARCHAR,
value='$[yyyy-MM-dd HH:mm:ss]'}, Property{prop='databus', direct=IN,
type=VARCHAR, value='databus'}, Property{prop='day_7ago_ymd_blackslash',
direct=IN, type=VARCHAR, value='$[yyyy/MM/dd-7]'},
Property{prop='day_1hourago_y_m_d', direct=IN, type=VARCHAR,
value='$[yyyy-MM-dd-1/24]'}, Property{prop='month_1ag
o', direct=IN, type=VARCHAR, value='$[MM-1]'},
Property{prop='target_username', direct=IN, type=VARCHAR, value='dw_user'},
Property{prop='day_2ago_y_m_d', direct=IN, type=VARCHAR,
value='$[yyyy-MM-dd-2]'}, Property{prop='day_ymd', direct=IN, type=VARCHAR,
value='$[yyyyMMdd]'}, Property{prop='day_1hourago_ymdh', direct=IN,
type=VARCHAR, value='$[yyyyMMddHH-1/24]'}, Property{prop='day_90ago_y_m_d',
direct=IN, type=VARCHAR, value='$[yyyy-MM-dd-90]'},
Property{prop='target_jdbc_url', direct=IN, type=VARCHAR,
value='jdbc:mysql://172.28.32.13:9030?characterEncoding=UTF-8&useUnicode=true&autoReconnect=true&useSSL=false&serverTimezone=Asia/Shanghai'},
Property{prop='dwd', direct=IN, type=VARCHAR, value='dfzx_dwd'},
Property{prop='day_1ago_y_m_d', direct=IN, type=VARCHAR,
value='$[yyyy-MM-dd-1]'}, Property{prop='target_database', direct=IN,
type=VARCHAR, value='databus'}, Property{prop='target_password', direct=IN,
type=VARCHAR, value='xdf@1314'}, Property{prop='ads', direct=IN, type=VARCHAR
, value='dfzx_ads'}, Property{prop='day_y_m_d', direct=IN, type=VARCHAR,
value='$[yyyy-MM-dd]'}, Property{prop='day_y_m_d_h_end', direct=IN,
type=VARCHAR, value='$[yyyy-MM-dd HH:59:59]'}, Property{prop='year_1ago',
direct=IN, type=VARCHAR, value='$[yyyy-1]'}, Property{prop='day_y_m_d_h',
direct=IN, type=VARCHAR, value='$[yyyy-MM-dd HH:00:00]'}, Property{prop='ods',
direct=IN, type=VARCHAR, value='dfzx_ods'}, Property{prop='day_4next_y_m_d',
direct=IN, type=VARCHAR, value='$[yyyy-MM-dd+4]'}],
globalParamMap={day_1hourago_ymd=$[yyyyMMdd-1/24], day_2ago_ymd=$[yyyyMMdd-2],
dws=dfzx_dws, day_ymdh=$[yyyyMMddHH], day_1ago=$[dd-1],
target_doris_fe_load_url=172.28.32.13:8030, day_1ago_ymd=$[yyyyMMdd-1],
target_url=172.28.32.13, day_1hourago_y_m_d_h=$[yyyy-MM-dd HH:00:00-1/24],
dim=dfzx_dim, day_30ago_y_m_d=$[yyyy-MM-dd-30],
day_60ago_y_m_d=$[yyyy-MM-dd-60], day_y_m_d_h_m=$[yyyy-MM-dd HH:mm:00],
target_port=9030, current=$[yyyy-MM-dd HH:mm:ss],
day_1ago_ymd_blackslash=$[yyyy/MM/dd-1], databus
=databus, day_7ago_ymd_blackslash=$[yyyy/MM/dd-7],
day_1hourago_y_m_d=$[yyyy-MM-dd-1/24], month_1ago=$[MM-1],
target_username=dw_user, day_2ago_y_m_d=$[yyyy-MM-dd-2], day_ymd=$[yyyyMMdd],
day_1hourago_ymdh=$[yyyyMMddHH-1/24], day_90ago_y_m_d=$[yyyy-MM-dd-90],
target_jdbc_url=jdbc:mysql://172.28.32.13:9030?characterEncoding=UTF-8&useUnicode=true&autoReconnect=true&useSSL=false&serverTimezone=Asia/Shanghai,
dwd=dfzx_dwd, ads=dfzx_ads, target_password=xdf@1314, target_database=databus,
day_1ago_y_m_d=$[yyyy-MM-dd-1], day_y_m_d=$[yyyy-MM-dd],
day_y_m_d_h_end=$[yyyy-MM-dd HH:59:59], year_1ago=$[yyyy-1],
day_y_m_d_h=$[yyyy-MM-dd HH:00:00], day_4next_y_m_d=$[yyyy-MM-dd+4],
ods=dfzx_ods}, createTime=Thu Feb 09 22:28:55 CST 2023, updateTime=Fri Apr 14
14:11:58 CST 2023, flag=YES, userId=1, userName=null, projectName=null,
locations=[{"taskCode":8879185625920,"x":80,"y":74},{"taskCode":8879185634624,"x":80,"y":154},{"taskCode":8879185631680,"x":80,"y":234},{"taskCode":8879185628736,"x":80,"y"
:314},{"taskCode":8879185622720,"x":80,"y":394}], scheduleReleaseState=null,
timeout=0, tenantId=-1, tenantCode=null, modifyBy=null, warningGroupId=0,
executionType=PARALLEL)
[INFO] 2023-04-16 22:34:14.809 +0800
org.apache.dolphinscheduler.service.alert.ProcessAlertManager:[266] -
[WorkflowInstance-693038][TaskInstance-null] - add alert to db , alert:
Alert{id=1614, sign='97d170e1550eee4afc0af065b78cda302a97674c',
title='scheduler failed', content='[]', alertStatus=null, warningType=FAILURE,
log='null', alertGroupId=4, createTime=Sun Apr 16 22:34:14 CST 2023,
updateTime=null, info={}}
[INFO] 2023-04-16 22:34:14.809 +0800
org.apache.dolphinscheduler.server.master.runner.WorkflowExecuteThreadPool:[136]
- [WorkflowInstance-693038][TaskInstance-0] - Workflow instance is finished
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
