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

fix(web): 修复获取 yarn 队列没有过滤集群

Browse Source
This commit is contained in:
兰缘小妖
2023-05-31 23:54:36 +08:00
parent 156ddf8033
commit d4c25c812e
2 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/YarnClusterService.java
View File

@@ -60,6 +60,10 @@ public class YarnClusterService {
return servicesMap.valuesView().toList().toImmutable(); return servicesMap.valuesView().toList().toImmutable();
} }
public ImmutableList<YarnService> services(ImmutableSet<String> clusters) {
return clusters.toList().collect(this::service).toImmutable();
}
public ImmutableMap<String, YarnService> servicesMap() { public ImmutableMap<String, YarnService> servicesMap() {
return servicesMap; return servicesMap;
} }

2
service-web/src/main/java/com/lanyuanxiaoyao/service/web/controller/YarnController.java
View File

@@ -109,7 +109,7 @@ public class YarnController extends BaseController {
public AmisResponse queueList(@RequestParam("clusters") List<String> clusters, @RequestParam(value = "names", defaultValue = "") String names) { public AmisResponse queueList(@RequestParam("clusters") List<String> clusters, @RequestParam(value = "names", defaultValue = "") String names) {
boolean isFilterNames = StrUtil.isNotBlank(names); boolean isFilterNames = StrUtil.isNotBlank(names);
ImmutableList<String> filterNames = Lists.immutable.of(names.split(",")); ImmutableList<String> filterNames = Lists.immutable.of(names.split(","));
ImmutableList<YarnClusterVO> results = yarnClusterService.services() ImmutableList<YarnClusterVO> results = yarnClusterService.services(Sets.immutable.ofAll(clusters))
.asParallel(EXECUTOR, 1) .asParallel(EXECUTOR, 1)
.collect(yarnService -> { .collect(yarnService -> {
YarnRootQueue cluster = yarnService.cluster(); YarnRootQueue cluster = yarnService.cluster();