From 3f8652395c9f37380d0683a13e11234a765ccd56 Mon Sep 17 00:00:00 2001 From: v-zhangjc9 Date: Mon, 14 Oct 2024 14:21:53 +0800 Subject: [PATCH] =?UTF-8?q?fix(scheduler):=20=E4=BF=AE=E5=A4=8D=E9=97=B2?= =?UTF-8?q?=E6=97=B6=E5=8E=8B=E7=BC=A9crm=E9=87=8D=E7=82=B9=E8=A1=A8?= =?UTF-8?q?=E8=B0=83=E5=BA=A6=E5=88=B0A4=E9=9B=86=E7=BE=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../scheduler/quartz/compaction/DistributeScheduleJob.java | 2 +- .../lanyuanxiaoyao/service/scheduler/utils/ScheduleHelper.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/service-scheduler/src/main/java/com/lanyuanxiaoyao/service/scheduler/quartz/compaction/DistributeScheduleJob.java b/service-scheduler/src/main/java/com/lanyuanxiaoyao/service/scheduler/quartz/compaction/DistributeScheduleJob.java index 6f67b02..db04630 100644 --- a/service-scheduler/src/main/java/com/lanyuanxiaoyao/service/scheduler/quartz/compaction/DistributeScheduleJob.java +++ b/service-scheduler/src/main/java/com/lanyuanxiaoyao/service/scheduler/quartz/compaction/DistributeScheduleJob.java @@ -70,7 +70,7 @@ public class DistributeScheduleJob extends BaseScheduleJob { if (cluster.isPresent() && cluster.get().available(metadata)) { return cluster.get().queue(); } else { - logger.warn(StrUtil.format("{} cluster not found or busy")); + logger.warn(StrUtil.format("{} cluster not found or busy", recommendCluster)); } } for (Cluster cluster : clusters) { diff --git a/service-scheduler/src/main/java/com/lanyuanxiaoyao/service/scheduler/utils/ScheduleHelper.java b/service-scheduler/src/main/java/com/lanyuanxiaoyao/service/scheduler/utils/ScheduleHelper.java index 5c1a1f1..f1924f0 100644 --- a/service-scheduler/src/main/java/com/lanyuanxiaoyao/service/scheduler/utils/ScheduleHelper.java +++ b/service-scheduler/src/main/java/com/lanyuanxiaoyao/service/scheduler/utils/ScheduleHelper.java @@ -117,7 +117,7 @@ public class ScheduleHelper { // 统一在这里覆盖特定请求 // CRM重点表独占A4集群 if (TagsHelper.existsTag(meta.getTags(), Constants.TAGS_CRM_FOCUS)) { - finalMetadata.put(Constants.SCHEDULE_FORCE, Constants.CLUSTER_A4); + finalMetadata.put(Constants.SCHEDULE_RECOMMEND, Constants.CLUSTER_A4); } else { finalMetadata.put(Constants.SCHEDULE_ESCAPE, Constants.CLUSTER_A4); }