[incubator-dolphinscheduler] branch dev updated: fix bug: zk hasTask method NPE (#1785)

[journey]

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

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


The following commit(s) were added to refs/heads/dev by this push:
     new 2ec9943  fix bug: zk hasTask method NPE (#1785)
2ec9943 is described below

commit 2ec9943f647d4e58c32d64278fe419ca9a71f4a5
Author: Yelli <51317527+yeleig...@users.noreply.github.com>
AuthorDate: Thu Jan 9 14:50:15 2020 +0800

    fix bug: zk hasTask method NPE (#1785)
---
 .../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 eb9e047..5f834a2 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
@@ -83,7 +83,7 @@ public class TaskQueueZkImpl implements ITaskQueue {
     @Override
     public boolean hasTask(String key) {
         try {
-            return zookeeperOperator.hasChildren(key);
+            return zookeeperOperator.hasChildren(getTasksPath(key));
         } catch (Exception e) {
             logger.error("check has task in tasks queue exception",e);
         }