[incubator-dolphinscheduler] branch 1.2.1-release updated: get root path from zookeeper config

[technoboy]

This is an automated email from the ASF dual-hosted git repository.

technoboy pushed a commit to branch 1.2.1-release
in repository https://gitbox.apache.org/repos/asf/incubator-dolphinscheduler.git


The following commit(s) were added to refs/heads/1.2.1-release by this push:
     new f057ef5  get root path from zookeeper config
     new 202a92a  Merge pull request #1695 from lgcareer/1.2.1-release-taskqueue
f057ef5 is described below

commit f057ef555699cfabd3a8f4365894fedb1483a287
Author: lgcareer <18610854...@163.com>
AuthorDate: Fri Jan 3 16:56:46 2020 +0800

    get root path from zookeeper config
---
 .../java/org/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 45c6122..03a6064 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;
     }
 
 }