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

fix(yarn-query): 移除重复的属性设置

Browse Source
This commit is contained in:
兰缘小妖
2023-05-10 10:01:40 +08:00
parent cc851158db
commit 0ed1840044
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
service-yarn-query/src/main/java/com/lanyuanxiaoyao/service/yarn/service/impl/JobServiceImpl.java
View File

@@ -52,14 +52,14 @@ public class JobServiceImpl implements JobService {
@Retryable(Throwable.class) @Retryable(Throwable.class)
@Override @Override
public ImmutableList<YarnApplication> listEquals(String name) throws JsonProcessingException { public ImmutableList<YarnApplication> listEquals(String name) throws JsonProcessingException {
return list().select(app -> StrUtil.equals(app.getName(), name)).tap(app -> app.setCluster(yarnConfiguration.getCluster())); return list().select(app -> StrUtil.equals(app.getName(), name));
} }
@Cacheable(value = "job-list", sync = true, key = "#{methodName+name}") @Cacheable(value = "job-list", sync = true, key = "#{methodName+name}")
@Retryable(Throwable.class) @Retryable(Throwable.class)
@Override @Override
public ImmutableList<YarnApplication> listLike(String name) throws JsonProcessingException { public ImmutableList<YarnApplication> listLike(String name) throws JsonProcessingException {
return list().select(app -> StrUtil.contains(app.getName(), name)).tap(app -> app.setCluster(yarnConfiguration.getCluster())); return list().select(app -> StrUtil.contains(app.getName(), name));
} }
@Override @Override