From 5add0d5d253c403e1af2949dcea56b9ba617e5f7 Mon Sep 17 00:00:00 2001 From: v-zhangjc9 Date: Mon, 6 May 2024 15:17:43 +0800 Subject: [PATCH] =?UTF-8?q?feat(scheduler):=20=E8=B0=83=E6=95=B4b12?= =?UTF-8?q?=E8=B5=84=E6=BA=90=E4=BD=BF=E7=94=A8=E4=B8=8A=E9=99=90?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../scheduler/quartz/distribute/cluster/B12Cluster.java | 2 +- .../scheduler/quartz/distribute/cluster/B5Cluster.java | 6 ------ 2 files changed, 1 insertion(+), 7 deletions(-) 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) - - )*/ ) ); }