Fix the problem of blank exec user.

WeDataSphere · Dec 6, 2024 · e1386b4 · e1386b4
1 parent 107316a
commit e1386b4
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/...atasphere/exchangis/job/server/builder/transform/GenericExchangisTransformJobBuilder.java b/...atasphere/exchangis/job/server/builder/transform/GenericExchangisTransformJobBuilder.java
@@ -83,7 +83,8 @@ public TransformExchangisJob buildJob(ExchangisJobInfo inputJob, TransformExchan
                 inputJob.getName(), inputJob.getId(), inputJob.getEngineType(), inputJob.getJobContent());
         //First to convert content to "ExchangisJobInfoContent"
         TransformExchangisJob outputJob = new TransformExchangisJob();
-        outputJob.setCreateUser(Optional.ofNullable(inputJob.getExecuteUser()).orElse(String.valueOf(ctx.getEnv("USER_NAME"))));
+        outputJob.setCreateUser(StringUtils.isNotBlank(inputJob.getExecuteUser()) ?
+                inputJob.getExecuteUser() : String.valueOf(ctx.getEnv("USER_NAME")));
         try {
             if (StringUtils.isNotBlank(inputJob.getJobContent())) {
                 //First to convert content to "ExchangisJobInfoContent"

diff --git a/...a/com/webank/wedatasphere/exchangis/job/server/service/impl/DefaultJobExecuteService.java b/...a/com/webank/wedatasphere/exchangis/job/server/service/impl/DefaultJobExecuteService.java
@@ -357,6 +357,8 @@ public String executeJob(String requestUser, ExchangisJobInfo jobInfo, String ex
         }
         // Build generator scheduler task
         GenerationSchedulerTask schedulerTask = null;
+        // Importance
+//        jobInfo.setExecuteUser(execUser);
         try {
             schedulerTask = new GenerationSchedulerTask(taskGenerator, jobInfo);
         } catch (ExchangisTaskGenerateException e) {