diff --git a/service-yarn-query/src/main/java/com/lanyuanxiaoyao/service/yarn/service/impl/JobServiceImpl.java b/service-yarn-query/src/main/java/com/lanyuanxiaoyao/service/yarn/service/impl/JobServiceImpl.java index 72c61c7..2814177 100644 --- a/service-yarn-query/src/main/java/com/lanyuanxiaoyao/service/yarn/service/impl/JobServiceImpl.java +++ b/service-yarn-query/src/main/java/com/lanyuanxiaoyao/service/yarn/service/impl/JobServiceImpl.java @@ -52,14 +52,14 @@ public class JobServiceImpl implements JobService { @Retryable(Throwable.class) @Override public ImmutableList 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}") @Retryable(Throwable.class) @Override public ImmutableList 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