From b51176e5c28b97787643f4273d60dc7f172fb4d8 Mon Sep 17 00:00:00 2001 From: v-zhangjc9 Date: Fri, 10 May 2024 17:28:54 +0800 Subject: [PATCH] =?UTF-8?q?feat(scheduler):=20=E5=A2=9E=E5=8A=A0b12?= =?UTF-8?q?=E9=9B=86=E7=BE=A4=E7=9A=84=E8=B5=84=E6=BA=90=E9=99=90=E5=88=B6?= =?UTF-8?q?=E4=B8=8A=E9=99=90?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/scheduler/quartz/distribute/cluster/B12Cluster.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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) ) ); }