diff --git a/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/executor/AnnotationMapReduceJobExecutor.java b/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/executor/AnnotationMapReduceJobExecutor.java
index d4a00d92..563981f9 100644
--- a/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/executor/AnnotationMapReduceJobExecutor.java
+++ b/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/executor/AnnotationMapReduceJobExecutor.java
@@ -57,15 +57,16 @@ public class AnnotationMapReduceJobExecutor extends AbstractMapReduceExecutor {
             throw new SnailJobMapReduceException("[{}] not found", mergeReduceArgs.getExecutorInfo());
         }
 
-        if (Objects.isNull(jobExecutorInfo.getReduceExecutor())) {
+        Method mergeReduceExecutor = jobExecutorInfo.getMergeReduceExecutor();
+        if (Objects.isNull(mergeReduceExecutor)) {
             throw new SnailJobMapReduceException(
                 "[{}] MapTask execution method not found. Please configure the @MergeReduceExecutor annotation",
                 mergeReduceArgs.getExecutorInfo());
         }
 
-        Class<?>[] paramTypes = jobExecutorInfo.getMergeReduceExecutor().getParameterTypes();
+        Class<?>[] paramTypes = mergeReduceExecutor.getParameterTypes();
         if (paramTypes.length > 0) {
-            return (ExecuteResult) ReflectionUtils.invokeMethod(jobExecutorInfo.getReduceExecutor(),
+            return (ExecuteResult) ReflectionUtils.invokeMethod(mergeReduceExecutor,
                 jobExecutorInfo.getExecutor(), mergeReduceArgs);
         }