From cd2ad0c37975c881c52e1740d98a0c12b1075b83 Mon Sep 17 00:00:00 2001 From: lenboo Date: Thu, 4 Jul 2019 20:44:14 +0800 Subject: [PATCH] update pull task --- .../main/java/cn/escheduler/common/queue/TaskQueueZkImpl.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) 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; }