feat(scheduler): 调整b12资源限制

2024-05-09 18:12:51 +08:00
parent def035fa90
commit bfdc5743ab
1 changed files with 1 additions and 1 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
@@ -23,7 +23,7 @@ public class B12Cluster extends Cluster {
                Constants.COMPACTION_QUEUE_B12,
                AvailableStrategy.and(
                        new QueueSizeLimit(client, Constants.COMPACTION_QUEUE_B12, 20),
-                        new YarnQueueUsedLimit(yarnService, Constants.CLUSTER_B12, "default", 1.0)
+                        new YarnQueueUsedLimit(yarnService, Constants.CLUSTER_B12, "default", 0.8)
                )
        );
    }