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);
                     }