From 0ed18400440fbd3b070baa2ab1e4f35bf3e1d24b Mon Sep 17 00:00:00 2001 From: lanyuanxiaoyao Date: Wed, 10 May 2023 10:01:40 +0800 Subject: [PATCH] =?UTF-8?q?fix(yarn-query):=20=E7=A7=BB=E9=99=A4=E9=87=8D?= =?UTF-8?q?=E5=A4=8D=E7=9A=84=E5=B1=9E=E6=80=A7=E8=AE=BE=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/yarn/service/impl/JobServiceImpl.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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