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);
         }