From 2ec9943f647d4e58c32d64278fe419ca9a71f4a5 Mon Sep 17 00:00:00 2001
From: Yelli <51317527+Yeleights@users.noreply.github.com>
Date: Thu, 9 Jan 2020 14:50:15 +0800
Subject: [PATCH] fix bug: zk hasTask method NPE (#1785)

---
 .../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 eb9e04753d..5f834a2004 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);
         }