diff --git a/easy-retry-server/easy-retry-server-job-task/src/main/java/com/aizuda/easy/retry/server/job/task/support/generator/task/BroadcastTaskGenerator.java b/easy-retry-server/easy-retry-server-job-task/src/main/java/com/aizuda/easy/retry/server/job/task/support/generator/task/BroadcastTaskGenerator.java index 85f75621..d2fb9c84 100644 --- a/easy-retry-server/easy-retry-server-job-task/src/main/java/com/aizuda/easy/retry/server/job/task/support/generator/task/BroadcastTaskGenerator.java +++ b/easy-retry-server/easy-retry-server-job-task/src/main/java/com/aizuda/easy/retry/server/job/task/support/generator/task/BroadcastTaskGenerator.java @@ -51,20 +51,20 @@ public class BroadcastTaskGenerator extends AbstractJobTaskGenerator { Set clientInfoSet = new HashSet<>(serverNodes.size()); List jobTasks = new ArrayList<>(serverNodes.size()); for (RegisterNodeInfo serverNode : serverNodes) { - String clientInfo = ClientInfoUtils.generate(serverNode); // 若存在相同的IP信息则去重 - if (clientInfoSet.contains(clientInfo)) { + String address = serverNode.address(); + if (clientInfoSet.contains(address)) { continue; } JobTask jobTask = JobTaskConverter.INSTANCE.toJobTaskInstance(context); - jobTask.setClientInfo(clientInfo); + jobTask.setClientInfo(ClientInfoUtils.generate(serverNode)); jobTask.setArgsType(context.getArgsType()); jobTask.setArgsStr(context.getArgsStr()); jobTask.setTaskStatus(JobTaskStatusEnum.RUNNING.getStatus()); jobTask.setResultMessage(Optional.ofNullable(jobTask.getResultMessage()).orElse(StrUtil.EMPTY)); Assert.isTrue(1 == jobTaskMapper.insert(jobTask), () -> new EasyRetryServerException("新增任务实例失败")); - clientInfoSet.add(clientInfo); + clientInfoSet.add(address); jobTasks.add(jobTask); }