gtsoft/gtsoft-snail-job-server
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects 1 Releases Wiki Activity

feat(sj_1.1.0-beta2): 优化异常信息

Browse Source
This commit is contained in:
opensnail 2024-06-26 18:08:43 +08:00
parent e658529f8f
commit 7e7ea0eb95
1 changed files with 9 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/executor/AnnotationMapReduceJobExecutor.java
View File

@ -31,11 +31,12 @@ public class AnnotationMapReduceJobExecutor extends AbstractMapReduceExecutor {
protected ExecuteResult doReduceExecute(final ReduceArgs reduceArgs) { protected ExecuteResult doReduceExecute(final ReduceArgs reduceArgs) {
JobExecutorInfo jobExecutorInfo = JobExecutorInfoCache.get(reduceArgs.getExecutorInfo()); JobExecutorInfo jobExecutorInfo = JobExecutorInfoCache.get(reduceArgs.getExecutorInfo());
if (Objects.isNull(jobExecutorInfo)) { if (Objects.isNull(jobExecutorInfo)) {
throw new SnailJobMapReduceException("[{}]未发现", reduceArgs.getExecutorInfo()); throw new SnailJobMapReduceException("[{}] not found", reduceArgs.getExecutorInfo());
} }
if (Objects.isNull(jobExecutorInfo.getReduceExecutor())) { if (Objects.isNull(jobExecutorInfo.getReduceExecutor())) {
throw new SnailJobMapReduceException("未发现ReduceTask执行方法, 请配置@ReduceExecutor注解", throw new SnailJobMapReduceException(
"[{}] MapTask execution method not found. Please configure the @ReduceExecutor annotation",
reduceArgs.getExecutorInfo()); reduceArgs.getExecutorInfo());
} }
@ -45,7 +46,7 @@ public class AnnotationMapReduceJobExecutor extends AbstractMapReduceExecutor {
jobExecutorInfo.getExecutor(), reduceArgs); jobExecutorInfo.getExecutor(), reduceArgs);
} }
throw new SnailJobMapReduceException("[{}]未发现ReduceTask执行方法", reduceArgs.getExecutorInfo()); throw new SnailJobMapReduceException("[{}] ReduceTask execution method not found", reduceArgs.getExecutorInfo());
} }
@Override @Override
@ -53,11 +54,12 @@ public class AnnotationMapReduceJobExecutor extends AbstractMapReduceExecutor {
JobExecutorInfo jobExecutorInfo = JobExecutorInfoCache.get(mergeReduceArgs.getExecutorInfo()); JobExecutorInfo jobExecutorInfo = JobExecutorInfoCache.get(mergeReduceArgs.getExecutorInfo());
if (Objects.isNull(jobExecutorInfo)) { if (Objects.isNull(jobExecutorInfo)) {
throw new SnailJobMapReduceException("[{}]未发现", mergeReduceArgs.getExecutorInfo()); throw new SnailJobMapReduceException("[{}] not found", mergeReduceArgs.getExecutorInfo());
} }
if (Objects.isNull(jobExecutorInfo.getReduceExecutor())) { if (Objects.isNull(jobExecutorInfo.getReduceExecutor())) {
throw new SnailJobMapReduceException("[{}]未发现ReduceTask执行方法, 请配置@MergeReduceExecutor注解", throw new SnailJobMapReduceException(
"[{}] MapTask execution method not found. Please configure the @MergeReduceExecutor annotation",
mergeReduceArgs.getExecutorInfo()); mergeReduceArgs.getExecutorInfo());
} }
@ -67,8 +69,9 @@ public class AnnotationMapReduceJobExecutor extends AbstractMapReduceExecutor {
jobExecutorInfo.getExecutor(), mergeReduceArgs); jobExecutorInfo.getExecutor(), mergeReduceArgs);
} }
throw new SnailJobMapReduceException("[{}]未发现MergeReduceTask执行方法 [{}]", throw new SnailJobMapReduceException("[{}] MergeReduceTask execution method not found [{}]",
mergeReduceArgs.getExecutorInfo()); mergeReduceArgs.getExecutorInfo());
} }
@Override @Override