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

fix(yarn-query): 修复 cache key 语法错误

Browse Source
This commit is contained in:
兰缘小妖
2023-06-02 17:32:48 +08:00
parent 7793deac4b
commit ca30543132
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -40,7 +40,7 @@ public class JobServiceImpl implements JobService {
this.mapper = builder.build(); this.mapper = builder.build();
} }
@Cacheable(value = "job-list", sync = true, key = "#cluster") @Cacheable(value = "job-list", sync = true)
@Retryable(Throwable.class) @Retryable(Throwable.class)
@Override @Override
public ImmutableList<YarnApplication> list(String cluster) throws JsonProcessingException { public ImmutableList<YarnApplication> list(String cluster) throws JsonProcessingException {
@@ -50,14 +50,14 @@ public class JobServiceImpl implements JobService {
} }
} }
@Cacheable(value = "job-list", sync = true, key = "#{methodName+cluster+name}") @Cacheable(value = "job-list", sync = true, key = "#methodName+#cluster+#name")
@Retryable(Throwable.class) @Retryable(Throwable.class)
@Override @Override
public ImmutableList<YarnApplication> listEquals(String cluster, String name) throws JsonProcessingException { public ImmutableList<YarnApplication> listEquals(String cluster, String name) throws JsonProcessingException {
return list(cluster).select(app -> StrUtil.equals(app.getName(), name)); return list(cluster).select(app -> StrUtil.equals(app.getName(), name));
} }
@Cacheable(value = "job-list", sync = true, key = "#{methodName+cluster+name}") @Cacheable(value = "job-list", sync = true, key = "#methodName+#cluster+#name")
@Retryable(Throwable.class) @Retryable(Throwable.class)
@Override @Override
public ImmutableList<YarnApplication> listLike(String cluster, String name) throws JsonProcessingException { public ImmutableList<YarnApplication> listLike(String cluster, String name) throws JsonProcessingException {