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 1af88ca..cfe7501 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", 1.0) + new YarnQueueUsedLimit(yarnService, Constants.CLUSTER_B12, "default", 0.8) ) ); }