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 * * ?") ) ); }