diff --git a/service-scheduler/src/main/java/com/lanyuanxiaoyao/service/scheduler/quartz/distribute/cluster/B5Cluster.java b/service-scheduler/src/main/java/com/lanyuanxiaoyao/service/scheduler/quartz/distribute/cluster/B5Cluster.java index 83ac29f..ffd06c6 100644 --- a/service-scheduler/src/main/java/com/lanyuanxiaoyao/service/scheduler/quartz/distribute/cluster/B5Cluster.java +++ b/service-scheduler/src/main/java/com/lanyuanxiaoyao/service/scheduler/quartz/distribute/cluster/B5Cluster.java @@ -2,9 +2,6 @@ package com.lanyuanxiaoyao.service.scheduler.quartz.distribute.cluster; import com.lanyuanxiaoyao.service.common.Constants; import com.lanyuanxiaoyao.service.forest.service.YarnService; -import com.lanyuanxiaoyao.service.scheduler.quartz.distribute.strategy.AvailableStrategy; -import com.lanyuanxiaoyao.service.scheduler.quartz.distribute.strategy.QueueSizeLimit; -import com.lanyuanxiaoyao.service.scheduler.quartz.distribute.strategy.YarnQueueUsedLimit; import org.springframework.cloud.client.discovery.DiscoveryClient; import org.springframework.stereotype.Component; @@ -21,10 +18,11 @@ public class B5Cluster extends Cluster { super( Constants.CLUSTER_B5, Constants.COMPACTION_QUEUE_B5, - AvailableStrategy.and( + /* AvailableStrategy.and( new QueueSizeLimit(client, Constants.COMPACTION_QUEUE_B5, 10), new YarnQueueUsedLimit(yarnService, Constants.CLUSTER_B5, "ten_iap.datalake", 0.9) - ) + ) */ + () -> false ); } }