This is an automated email from the ASF dual-hosted git repository.
wenjun pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
The following commit(s) were added to refs/heads/dev by this push:
new ac04288e2b fix the full log path of logical task is not be set when
task is dispatched (#14819) (#14821)
ac04288e2b is described below
commit ac04288e2b5a61738347696ac1fb844b627b579c
Author: sgw <[email protected]>
AuthorDate: Sun Aug 27 12:24:04 2023 +0800
fix the full log path of logical task is not be set when task is dispatched
(#14819) (#14821)
---
.../server/master/rpc/LogicITaskInstanceDispatchOperationFunction.java | 2 ++
1 file changed, 2 insertions(+)
diff --git
a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/rpc/LogicITaskInstanceDispatchOperationFunction.java
b/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/rpc/LogicITaskInstanceDispatchOperationFunction.java
index 22258c613b..d97cdea0aa 100644
---
a/dolphinscheduler-master/src/main/java/org/apache/dolphinscheduler/server/master/rpc/LogicITaskInstanceDispatchOperationFunction.java
+++
b/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 String taskInstanceName = taskExecutionContext.getTaskName();
+
taskExecutionContext.setLogPath(LogUtils.getTaskInstanceLogFullPath(taskExecutionContext));
+
LogUtils.setWorkflowAndTaskInstanceIDMDC(workflowInstanceId,
taskInstanceId);
LogUtils.setTaskInstanceLogFullPathMDC(taskExecutionContext.getLogPath());