Fix the problem in log path.

WeDataSphere · Dec 23, 2024 · 07895a3 · 07895a3
1 parent e1386b4
commit 07895a3
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...ava/com/webank/wedatasphere/exchangis/job/launcher/entity/LaunchedExchangisJobEntity.java b/...ava/com/webank/wedatasphere/exchangis/job/launcher/entity/LaunchedExchangisJobEntity.java
@@ -5,6 +5,7 @@
 
 import com.webank.wedatasphere.exchangis.job.launcher.domain.LaunchableExchangisJob;
 import org.apache.commons.io.IOUtils;
+import org.apache.commons.lang3.StringUtils;
 
 import java.text.SimpleDateFormat;
 import java.util.Calendar;
@@ -65,7 +66,8 @@ public LaunchedExchangisJobEntity(LaunchableExchangisJob job){
         this.jobExecutionId = job.getJobExecutionId();
         this.jobParams = job.getJobParams();
         SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");
-        String logPath = this.executeUser + IOUtils.DIR_SEPARATOR_UNIX +
+        String logPath = StringUtils.isNotBlank(this.executeUser)? this.executeUser : this.createUser
+                + IOUtils.DIR_SEPARATOR_UNIX +
                 simpleDateFormat.format(new Date()) + IOUtils.DIR_SEPARATOR_UNIX + this.jobExecutionId;
         logPath = EnvironmentUtils.getServerAddress() + "@" + logPath;
         this.logPath = logPath;