From 8090f1450471f02868569f3f6c43f0e22788eb1d Mon Sep 17 00:00:00 2001
From: lgcareer <18610854716@163.com>
Date: Fri, 3 Jan 2020 18:05:00 +0800
Subject: [PATCH] get root path from zookeeper config

---
 .../apache/dolphinscheduler/common/queue/TaskQueueZkImpl.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/queue/TaskQueueZkImpl.java b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/queue/TaskQueueZkImpl.java
index 45c6122341..03a6064535 100644
--- a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/queue/TaskQueueZkImpl.java
+++ b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/queue/TaskQueueZkImpl.java
@@ -344,7 +344,7 @@ public class TaskQueueZkImpl implements ITaskQueue {
      * @return
      */
     public String getTasksPath(String key){
-        return "/dolphinscheduler" + Constants.SINGLE_SLASH + key;
+        return zookeeperOperator.getZookeeperConfig().getDsRoot() + Constants.SINGLE_SLASH + key;
     }
 
 }