diff --git a/escheduler-common/src/main/java/cn/escheduler/common/queue/TaskQueueZkImpl.java b/escheduler-common/src/main/java/cn/escheduler/common/queue/TaskQueueZkImpl.java
index 2c2e3ef4d9..e116cd3271 100644
--- a/escheduler-common/src/main/java/cn/escheduler/common/queue/TaskQueueZkImpl.java
+++ b/escheduler-common/src/main/java/cn/escheduler/common/queue/TaskQueueZkImpl.java
@@ -166,9 +166,8 @@ public class TaskQueueZkImpl extends AbstractZKClient implements ITaskQueue {
                             String taskHosts = taskDetailArrs[4];
 
                             //task can assign to any worker host if equals default ip value of worker server
-                            if(!taskHosts.equals(Constants.DEFAULT_WORKER_ID)){
+                            if(!taskHosts.equals(String.valueOf(Constants.DEFAULT_WORKER_ID))){
                                 String[] taskHostsArr = taskHosts.split(Constants.COMMA);
-
                                 if(!Arrays.asList(taskHostsArr).contains(workerIpLongStr)){
                                     continue;
                                 }