diff --git a/powerjob-server/powerjob-server-remote/src/main/java/tech/powerjob/server/remote/worker/WorkerClusterQueryService.java b/powerjob-server/powerjob-server-remote/src/main/java/tech/powerjob/server/remote/worker/WorkerClusterQueryService.java index 2cbef0951e0e3c192bfc573f3033ffaf606a5b4c..a931e3314653e4f1392087e0b7b785ee214bd158 100644 --- a/powerjob-server/powerjob-server-remote/src/main/java/tech/powerjob/server/remote/worker/WorkerClusterQueryService.java +++ b/powerjob-server/powerjob-server-remote/src/main/java/tech/powerjob/server/remote/worker/WorkerClusterQueryService.java @@ -76,6 +76,7 @@ public class WorkerClusterQueryService { * @param appId appId * @return alive workers */ + @DesignateServer public List getAllAliveWorkers(Long appId) { List workers = Lists.newLinkedList(getWorkerInfosByAppId(appId).values()); workers.removeIf(WorkerInfo::timeout);