From 7249419624ea57d6eaf74fcc479f0b844f0a9356 Mon Sep 17 00:00:00 2001 From: v-zhangjc9 Date: Mon, 14 Oct 2024 15:23:15 +0800 Subject: [PATCH] =?UTF-8?q?feat(scheduler):=20=E5=BE=AE=E8=B0=83b12?= =?UTF-8?q?=E9=9B=86=E7=BE=A4=E7=9A=84=E8=B5=84=E6=BA=90=E9=99=90=E5=88=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service-cli-runner/src/main/resources/application-b12.yml | 2 +- .../service/scheduler/quartz/distribute/cluster/B12Cluster.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/service-cli/service-cli-runner/src/main/resources/application-b12.yml b/service-cli/service-cli-runner/src/main/resources/application-b12.yml index b2fe4e7..7d83983 100644 --- a/service-cli/service-cli-runner/src/main/resources/application-b12.yml +++ b/service-cli/service-cli-runner/src/main/resources/application-b12.yml @@ -69,7 +69,7 @@ deploy: service-launcher-a4: replicas: 6 service-launcher-b12: - replicas: 10 + replicas: 15 service-info-query: replicas: 10 service-yarn-query: 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 1af88ca..89b5105 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 @@ -22,7 +22,7 @@ public class B12Cluster extends Cluster { Constants.CLUSTER_B12, Constants.COMPACTION_QUEUE_B12, AvailableStrategy.and( - new QueueSizeLimit(client, Constants.COMPACTION_QUEUE_B12, 20), + new QueueSizeLimit(client, Constants.COMPACTION_QUEUE_B12, 50), new YarnQueueUsedLimit(yarnService, Constants.CLUSTER_B12, "default", 1.0) ) );