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());
 

Reply via email to