feat(all): 移除b5集群

This commit is contained in:
v-zhangjc9
2024-10-14 14:32:43 +08:00
parent 6dbad6825d
commit b3ccbce16e
14 changed files with 3 additions and 2093 deletions

View File

@@ -1,28 +0,0 @@
package com.lanyuanxiaoyao.service.scheduler.quartz.distribute.cluster;
import com.lanyuanxiaoyao.service.common.Constants;
import com.lanyuanxiaoyao.service.forest.service.YarnService;
import org.springframework.cloud.client.discovery.DiscoveryClient;
import org.springframework.stereotype.Component;
/**
* B5
*
* @author lanyuanxiaoyao
* @date 2023-06-08
*/
@SuppressWarnings("SpringJavaInjectionPointsAutowiringInspection")
@Component
public class B5Cluster extends Cluster {
public B5Cluster(DiscoveryClient client, YarnService yarnService) {
super(
Constants.CLUSTER_B5,
Constants.COMPACTION_QUEUE_B5,
/* AvailableStrategy.and(
new QueueSizeLimit(client, Constants.COMPACTION_QUEUE_B5, 10),
new YarnQueueUsedLimit(yarnService, Constants.CLUSTER_B5, "ten_iap.datalake", 0.9)
) */
metadata -> false
);
}
}