lanyuanxiaoyao/hudi-service
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(scheduler): 修复闲时压缩crm重点表调度到A4集群

Browse Source
This commit is contained in:
v-zhangjc9
2024-10-14 14:21:53 +08:00
parent 8c6e0aa353
commit 3f8652395c
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
service-scheduler/src/main/java/com/lanyuanxiaoyao/service/scheduler/quartz/compaction/DistributeScheduleJob.java
View File

@@ -70,7 +70,7 @@ public class DistributeScheduleJob extends BaseScheduleJob {
if (cluster.isPresent() && cluster.get().available(metadata)) { if (cluster.isPresent() && cluster.get().available(metadata)) {
return cluster.get().queue(); return cluster.get().queue();
} else { } else {
logger.warn(StrUtil.format("{} cluster not found or busy")); logger.warn(StrUtil.format("{} cluster not found or busy", recommendCluster));
} }
} }
for (Cluster cluster : clusters) { for (Cluster cluster : clusters) {

2
service-scheduler/src/main/java/com/lanyuanxiaoyao/service/scheduler/utils/ScheduleHelper.java
View File

@@ -117,7 +117,7 @@ public class ScheduleHelper {
// 统一在这里覆盖特定请求 // 统一在这里覆盖特定请求
// CRM重点表独占A4集群 // CRM重点表独占A4集群
if (TagsHelper.existsTag(meta.getTags(), Constants.TAGS_CRM_FOCUS)) { 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 { } else {
finalMetadata.put(Constants.SCHEDULE_ESCAPE, Constants.CLUSTER_A4); finalMetadata.put(Constants.SCHEDULE_ESCAPE, Constants.CLUSTER_A4);
} }