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

fix(sj_1.1.0-beta2): 修复注解mergeReduce执行失败问题

Browse Source
This commit is contained in:
opensnail 2024-06-26 23:36:49 +08:00
parent b9f9a9e00f
commit dd03b837ef
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -57,15 +57,16 @@ public class AnnotationMapReduceJobExecutor extends AbstractMapReduceExecutor {
throw new SnailJobMapReduceException("[{}] not found", mergeReduceArgs.getExecutorInfo()); throw new SnailJobMapReduceException("[{}] not found", mergeReduceArgs.getExecutorInfo());
} }
if (Objects.isNull(jobExecutorInfo.getReduceExecutor())) { Method mergeReduceExecutor = jobExecutorInfo.getMergeReduceExecutor();
if (Objects.isNull(mergeReduceExecutor)) {
throw new SnailJobMapReduceException( throw new SnailJobMapReduceException(
"[{}] MapTask execution method not found. Please configure the @MergeReduceExecutor annotation", "[{}] MapTask execution method not found. Please configure the @MergeReduceExecutor annotation",
mergeReduceArgs.getExecutorInfo()); mergeReduceArgs.getExecutorInfo());
} }
Class<?>[] paramTypes = jobExecutorInfo.getMergeReduceExecutor().getParameterTypes(); Class<?>[] paramTypes = mergeReduceExecutor.getParameterTypes();
if (paramTypes.length > 0) { if (paramTypes.length > 0) {
return (ExecuteResult) ReflectionUtils.invokeMethod(jobExecutorInfo.getReduceExecutor(), return (ExecuteResult) ReflectionUtils.invokeMethod(mergeReduceExecutor,
jobExecutorInfo.getExecutor(), mergeReduceArgs); jobExecutorInfo.getExecutor(), mergeReduceArgs);
} }