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) ) );