feat(scheduler): 增加b12集群的资源限制上限
This commit is contained in:
@@ -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", 0.8)
|
||||
new YarnQueueUsedLimit(yarnService, Constants.CLUSTER_B12, "default", 0.9)
|
||||
)
|
||||
);
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user