lanyuanxiaoyao/hudi-service
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(all): 补充b9集群配置

Browse Source
This commit is contained in:
兰缘小妖
2024-02-29 18:30:43 +08:00
parent 54f2738b2e
commit e9aa11a15d
6 changed files with 42 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
service-cli/service-cli-runner/src/main/resources/application-b9.yml
View File

@@ -27,6 +27,10 @@ deploy:
authority: ENC(GXKnbq1LS11U2HaONspvH+D/TkIx13aWTaokdkzaF7HSvq6Z0Rv1+JUWFnYopVXu)
username: ENC(moIO5mO39V1Z+RDwROK9JXY4GfM8ZjDgM6Si7wRZ1MPVjbhTpmLz3lz28rAiw7c2LeCmizfJzHkEXIwGlB280g==)
darkcode: ENC(0jzpQ7T6S+P7bZrENgYsUoLhlqGvw7DA2MN3BRqEOwq7plhtg72vuuiPQNnr3DaYz0CpyTvxInhpx11W3VZ1trD6NINh7O3LN70ZqO5pWXk=)
yarn:
store-cluster: b9
sync-clusters: b9
compaction-clusters: b9
hosts:
b9s1_hdp_dc:
ip: 132.126.207.34

2
service-common/src/main/java/com/lanyuanxiaoyao/service/common/Constants.java
View File

@@ -190,11 +190,13 @@ public interface Constants {
String COMPACTION_QUEUE_B5 = "compaction-queue-b5";
String COMPACTION_QUEUE_A4 = "compaction-queue-a4";
String COMPACTION_QUEUE_B12 = "compaction-queue-b12";
String COMPACTION_QUEUE_B9 = "compaction-queue-b9";
String CLUSTER_B1 = "b1";
String CLUSTER_B5 = "b5";
String CLUSTER_A4 = "a4";
String CLUSTER_B12 = "b12";
String CLUSTER_B9 = "b9";
String SCHEDULE_JOB_FAIL_COUNT = "SCHEDULE_JOB_FAIL_COUNT";

3
service-configuration/src/main/java/com/lanyuanxiaoyao/service/configuration/entity/yarn/YarnClusters.java
View File

@@ -22,10 +22,9 @@ public class YarnClusters {
MapUtil.<String, Cluster>builder()
.put("a4", new Cluster("http://132.121.107.91:8088"))
.put("b1", new Cluster("http://132.122.98.13:8088"))
.put("b4", new Cluster("http://132.122.112.30:8088"))
.put("b5", new Cluster("http://132.122.116.12:8088"))
.put("t5", new Cluster("http://132.121.126.84:8088"))
.put("b12", new Cluster("http://132.126.207.125:8088"))
.put("b9", new Cluster("http://132.126.207.32:8088"))
.build()
);

11
service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/launcher/B9LauncherService.java
View File

@@ -1,11 +0,0 @@
package com.lanyuanxiaoyao.service.forest.service.launcher;
import com.dtflys.forest.annotation.BaseRequest;
/**
* @author lanyuanxiaoyao
* @date 2023-06-06
*/
@BaseRequest(baseURL = "http://service-launcher-runner-b9")
public interface B9LauncherService extends LauncherService{
}

12
service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/launcher/impl/B9LauncherService.java Normal file
View File

@@ -0,0 +1,12 @@
package com.lanyuanxiaoyao.service.forest.service.launcher.impl;
import com.dtflys.forest.annotation.BaseRequest;
import com.lanyuanxiaoyao.service.forest.service.launcher.LauncherService;
/**
* @author lanyuanxiaoyao
* @date 2023-06-06
*/
@BaseRequest(baseURL = "http://service-launcher-runner-b9")
public interface B9LauncherService extends LauncherService {
}

23
service-scheduler/src/main/java/com/lanyuanxiaoyao/service/scheduler/quartz/distribute/cluster/B9Cluster.java Normal file
View File

@@ -0,0 +1,23 @@
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;
/**
* A4
*
* @author lanyuanxiaoyao
* @date 2023-06-08
*/
@SuppressWarnings("SpringJavaInjectionPointsAutowiringInspection")
@Component
public class B9Cluster extends Cluster {
public B9Cluster(DiscoveryClient client, YarnService yarnService) {
super(
Constants.CLUSTER_B9,
Constants.COMPACTION_QUEUE_B9
);
}
}