From 0588c4a707bcac6a508bd0c59244a67a56f13823 Mon Sep 17 00:00:00 2001 From: yang Date: Sat, 21 Nov 2020 22:57:26 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9xxl-job=E6=9C=8D=E5=8A=A1?= =?UTF-8?q?=E5=99=A8=E5=9C=B0=E5=9D=80=E8=AE=BE=E7=BD=AEsetAddress?= =?UTF-8?q?=E6=94=B9=E4=B8=BAsetAdminAddresses?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/pig4cloud/pig/common/job/XxlJobAutoConfiguration.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pig-common/pig-common-job/src/main/java/com/pig4cloud/pig/common/job/XxlJobAutoConfiguration.java b/pig-common/pig-common-job/src/main/java/com/pig4cloud/pig/common/job/XxlJobAutoConfiguration.java index b46d6675..c5cf2adc 100644 --- a/pig-common/pig-common-job/src/main/java/com/pig4cloud/pig/common/job/XxlJobAutoConfiguration.java +++ b/pig-common/pig-common-job/src/main/java/com/pig4cloud/pig/common/job/XxlJobAutoConfiguration.java @@ -51,10 +51,10 @@ public class XxlJobAutoConfiguration { .flatMap(s -> discoveryClient.getInstances(s).stream()).map(instance -> String .format("http://%s:%s/%s", instance.getHost(), instance.getPort(), XXL_JOB_ADMIN)) .collect(Collectors.joining(",")); - xxlJobSpringExecutor.setAddress(serverList); + xxlJobSpringExecutor.setAdminAddresses(serverList); } else { - xxlJobSpringExecutor.setAddress(xxlJobProperties.getAdmin().getAddresses()); + xxlJobSpringExecutor.setAdminAddresses(xxlJobProperties.getAdmin().getAddresses()); } return xxlJobSpringExecutor;