[GitHub] [incubator-dolphinscheduler] Technoboy- commented on a change in pull request #1700: Fixed tasks_queue and tasks_kill did not exist in zookeeper #1696

[GitBox <gi...@apache.org>]

Technoboy- commented on a change in pull request #1700: Fixed tasks_queue and tasks_kill did not exist in zookeeper #1696
URL: https://github.com/apache/incubator-dolphinscheduler/pull/1700#discussion_r362776722
 
 

 ##########
 File path: dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/queue/TaskQueueZkImpl.java
 ##########
 @@ -37,8 +37,27 @@
 
     private static final Logger logger = LoggerFactory.getLogger(TaskQueueZkImpl.class);
 
+    private final ZookeeperOperator zookeeperOperator;
+
     @Autowired
-    private ZookeeperOperator zookeeperOperator;
+    public TaskQueueZkImpl(ZookeeperOperator zookeeperOperator) {
+        this.zookeeperOperator = zookeeperOperator;
+
+        try {
+            String tasksQueuePath = getTasksPath(Constants.DOLPHINSCHEDULER_TASKS_QUEUE);
+            String tasksCancelPath = getTasksPath(Constants.DOLPHINSCHEDULER_TASKS_KILL);
 
 Review comment:
   tasksCancelPath  -->     tasksKillPath

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services