From 46bf965f8191b4eb6557c4c4e1d1c88653ea33cf Mon Sep 17 00:00:00 2001
From: qiaozhanwei <825193156@qq.com>
Date: Tue, 2 Jul 2019 18:26:14 +0800
Subject: [PATCH] update

---
 .../cn/escheduler/server/worker/runner/FetchTaskThread.java  | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/escheduler-server/src/main/java/cn/escheduler/server/worker/runner/FetchTaskThread.java b/escheduler-server/src/main/java/cn/escheduler/server/worker/runner/FetchTaskThread.java
index 1c328b6cba..1c6232bc9a 100644
--- a/escheduler-server/src/main/java/cn/escheduler/server/worker/runner/FetchTaskThread.java
+++ b/escheduler-server/src/main/java/cn/escheduler/server/worker/runner/FetchTaskThread.java
@@ -211,9 +211,12 @@ public class FetchTaskThread implements Runnable{
                             // set task execute path
                             taskInstance.setExecutePath(execLocalPath);
 
+                            Tenant tenant = processDao.getTenantForProcess(processInstance.getTenantId(),
+                                    processDefine.getUserId());
+
                             // check and create Linux users
                             FileUtils.createWorkDirAndUserIfAbsent(execLocalPath,
-                                    processInstance.getTenantCode(), logger);
+                                    tenant.getTenantCode(), logger);
 
                             logger.info("task : {} ready to submit to task scheduler thread",taskId);
                             // submit task