From 2b7b7f838cafb0726dac2a4718b4bdb79e37fbd7 Mon Sep 17 00:00:00 2001 From: v-zhangjc9 Date: Wed, 22 May 2024 13:10:36 +0800 Subject: [PATCH] =?UTF-8?q?feat(scheduler):=20=E6=9A=82=E5=81=9Cb5?= =?UTF-8?q?=E7=9A=84=E5=8E=8B=E7=BC=A9=E8=B0=83=E5=BA=A6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../scheduler/quartz/distribute/cluster/B5Cluster.java | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) 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 83ac29f..ffd06c6 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 @@ -2,9 +2,6 @@ package com.lanyuanxiaoyao.service.scheduler.quartz.distribute.cluster; import com.lanyuanxiaoyao.service.common.Constants; import com.lanyuanxiaoyao.service.forest.service.YarnService; -import com.lanyuanxiaoyao.service.scheduler.quartz.distribute.strategy.AvailableStrategy; -import com.lanyuanxiaoyao.service.scheduler.quartz.distribute.strategy.QueueSizeLimit; -import com.lanyuanxiaoyao.service.scheduler.quartz.distribute.strategy.YarnQueueUsedLimit; import org.springframework.cloud.client.discovery.DiscoveryClient; import org.springframework.stereotype.Component; @@ -21,10 +18,11 @@ public class B5Cluster extends Cluster { super( Constants.CLUSTER_B5, Constants.COMPACTION_QUEUE_B5, - AvailableStrategy.and( + /* AvailableStrategy.and( new QueueSizeLimit(client, Constants.COMPACTION_QUEUE_B5, 10), new YarnQueueUsedLimit(yarnService, Constants.CLUSTER_B5, "ten_iap.datalake", 0.9) - ) + ) */ + () -> false ); } }