Commit f057ef55 authored by lgcareer's avatar lgcareer
Browse files

get root path from zookeeper config

parent bf11daaa

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;

    }



}