diff --git a/service-scheduler/src/main/java/com/lanyuanxiaoyao/service/scheduler/quartz/distribute/cluster/B12Cluster.java b/service-scheduler/src/main/java/com/lanyuanxiaoyao/service/scheduler/quartz/distribute/cluster/B12Cluster.java index cfe7501..1af88ca 100644 --- a/service-scheduler/src/main/java/com/lanyuanxiaoyao/service/scheduler/quartz/distribute/cluster/B12Cluster.java +++ b/service-scheduler/src/main/java/com/lanyuanxiaoyao/service/scheduler/quartz/distribute/cluster/B12Cluster.java @@ -23,7 +23,7 @@ public class B12Cluster extends Cluster { Constants.COMPACTION_QUEUE_B12, AvailableStrategy.and( new QueueSizeLimit(client, Constants.COMPACTION_QUEUE_B12, 20), - new YarnQueueUsedLimit(yarnService, Constants.CLUSTER_B12, "default", 0.8) + new YarnQueueUsedLimit(yarnService, Constants.CLUSTER_B12, "default", 1.0) ) ); } 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 595c6be..83ac29f 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 @@ -24,12 +24,6 @@ public class B5Cluster extends Cluster { AvailableStrategy.and( new QueueSizeLimit(client, Constants.COMPACTION_QUEUE_B5, 10), new YarnQueueUsedLimit(yarnService, Constants.CLUSTER_B5, "ten_iap.datalake", 0.9) - /*AvailableStrategy.whether( - new DatetimeLimit("* * 0-1 * * ?"), - new YarnQueueUsedLimit(yarnService, Constants.CLUSTER_B5, "ten_iap.datalake", 0.9), - new YarnQueueUsedLimit(yarnService, Constants.CLUSTER_B5, "ten_iap.datalake", 0.5) - - )*/ ) ); }