From 8c6e0aa353ea40058a5b91bf3ee437a6e491b75a Mon Sep 17 00:00:00 2001 From: v-zhangjc9 Date: Mon, 14 Oct 2024 10:55:36 +0800 Subject: [PATCH] =?UTF-8?q?feat(scheduler):=20=E7=A6=81=E6=AD=A2b5?= =?UTF-8?q?=E3=80=81a4=E5=9C=A8=E9=97=B2=E6=97=B6=E8=B0=83=E5=BA=A6?= =?UTF-8?q?=E6=9C=9F=E9=97=B4=E4=BD=BF=E7=94=A8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../scheduler/quartz/distribute/cluster/A4Cluster.java | 4 +++- .../scheduler/quartz/distribute/cluster/B1Cluster.java | 4 +++- 2 files changed, 6 insertions(+), 2 deletions(-) diff --git a/service-scheduler/src/main/java/com/lanyuanxiaoyao/service/scheduler/quartz/distribute/cluster/A4Cluster.java b/service-scheduler/src/main/java/com/lanyuanxiaoyao/service/scheduler/quartz/distribute/cluster/A4Cluster.java index 0cd717d..da11d0a 100644 --- a/service-scheduler/src/main/java/com/lanyuanxiaoyao/service/scheduler/quartz/distribute/cluster/A4Cluster.java +++ b/service-scheduler/src/main/java/com/lanyuanxiaoyao/service/scheduler/quartz/distribute/cluster/A4Cluster.java @@ -3,6 +3,7 @@ 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.DatetimeLimit; 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; @@ -23,7 +24,8 @@ public class A4Cluster extends Cluster { Constants.COMPACTION_QUEUE_A4, AvailableStrategy.and( new QueueSizeLimit(client, Constants.COMPACTION_QUEUE_A4, 10), - new YarnQueueUsedLimit(yarnService, Constants.CLUSTER_A4, "ten_iap.datalake", 0.8) + new YarnQueueUsedLimit(yarnService, Constants.CLUSTER_A4, "ten_iap.datalake", 0.8), + new DatetimeLimit(false, "* * 7-22 * * ?") ) ); } diff --git a/service-scheduler/src/main/java/com/lanyuanxiaoyao/service/scheduler/quartz/distribute/cluster/B1Cluster.java b/service-scheduler/src/main/java/com/lanyuanxiaoyao/service/scheduler/quartz/distribute/cluster/B1Cluster.java index a101f82..e080de2 100644 --- a/service-scheduler/src/main/java/com/lanyuanxiaoyao/service/scheduler/quartz/distribute/cluster/B1Cluster.java +++ b/service-scheduler/src/main/java/com/lanyuanxiaoyao/service/scheduler/quartz/distribute/cluster/B1Cluster.java @@ -3,6 +3,7 @@ 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.DatetimeLimit; 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; @@ -23,7 +24,8 @@ public class B1Cluster extends Cluster { Constants.COMPACTION_QUEUE_B1, AvailableStrategy.and( new QueueSizeLimit(client, Constants.COMPACTION_QUEUE_B1, 20), - new YarnQueueUsedLimit(yarnService, Constants.CLUSTER_B1, "datalake", 1.0) + new YarnQueueUsedLimit(yarnService, Constants.CLUSTER_B1, "datalake", 1.0), + new DatetimeLimit(false, "* * 7-22 * * ?") ) ); }