feat(scheduler): 微调b12集群的资源限制

2024-10-14 15:23:15 +08:00
parent 8e8b1a7684
commit 9fd46b3a20
2 changed files with 2 additions and 2 deletions
--- 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)
                )
        );