Browse Source

fix the full log path of logical task is not be set when task is dispatched (#14819) (#14821)

3.2.1-prepare
sgw 1 year ago committed by GitHub
parent
commit
ac04288e2b
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
  1. 2
      dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/rpc/LogicITaskInstanceDispatchOperationFunction.java

2
dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/rpc/LogicITaskInstanceDispatchOperationFunction.java

@ -56,6 +56,8 @@ public class LogicITaskInstanceDispatchOperationFunction
final int workflowInstanceId = taskExecutionContext.getProcessInstanceId(); final int workflowInstanceId = taskExecutionContext.getProcessInstanceId();
final String taskInstanceName = taskExecutionContext.getTaskName(); final String taskInstanceName = taskExecutionContext.getTaskName();
taskExecutionContext.setLogPath(LogUtils.getTaskInstanceLogFullPath(taskExecutionContext));
LogUtils.setWorkflowAndTaskInstanceIDMDC(workflowInstanceId, taskInstanceId); LogUtils.setWorkflowAndTaskInstanceIDMDC(workflowInstanceId, taskInstanceId);
LogUtils.setTaskInstanceLogFullPathMDC(taskExecutionContext.getLogPath()); LogUtils.setTaskInstanceLogFullPathMDC(taskExecutionContext.getLogPath());

Loading…
Cancel
Save