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..8e31971 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", 0.9) ) ); }