Unverified Commit 202a92af authored by Tboy's avatar Tboy Committed by GitHub
Browse files

Merge pull request #1695 from lgcareer/1.2.1-release-taskqueue 

get root path from zookeeper config
parents 5fa5a8b9 f057ef55

dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/queue/TaskQueueZkImpl.java

+1 −1
Original line number Diff line number Diff line
@@ -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;

    }



}