From 7e7ea0eb95f1a56501869fb9fd63492aece457f5 Mon Sep 17 00:00:00 2001
From: opensnail <598092184@qq.com>
Date: Wed, 26 Jun 2024 18:08:43 +0800
Subject: [PATCH] =?UTF-8?q?feat(sj=5F1.1.0-beta2):=20=E4=BC=98=E5=8C=96?=
 =?UTF-8?q?=E5=BC=82=E5=B8=B8=E4=BF=A1=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../executor/AnnotationMapReduceJobExecutor.java  | 15 +++++++++------
 1 file changed, 9 insertions(+), 6 deletions(-)

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 bf32eb406..d4a00d927 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
@@ -31,11 +31,12 @@ public class AnnotationMapReduceJobExecutor extends AbstractMapReduceExecutor {
     protected ExecuteResult doReduceExecute(final ReduceArgs reduceArgs) {
         JobExecutorInfo jobExecutorInfo = JobExecutorInfoCache.get(reduceArgs.getExecutorInfo());
         if (Objects.isNull(jobExecutorInfo)) {
-            throw new SnailJobMapReduceException("[{}]未发现", reduceArgs.getExecutorInfo());
+            throw new SnailJobMapReduceException("[{}] not found", reduceArgs.getExecutorInfo());
         }
 
         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());
         }
 
@@ -45,7 +46,7 @@ public class AnnotationMapReduceJobExecutor extends AbstractMapReduceExecutor {
                 jobExecutorInfo.getExecutor(), reduceArgs);
         }
 
-        throw new SnailJobMapReduceException("[{}]未发现ReduceTask执行方法", reduceArgs.getExecutorInfo());
+        throw new SnailJobMapReduceException("[{}] ReduceTask execution method not found", reduceArgs.getExecutorInfo());
     }
 
     @Override
@@ -53,11 +54,12 @@ public class AnnotationMapReduceJobExecutor extends AbstractMapReduceExecutor {
         JobExecutorInfo jobExecutorInfo = JobExecutorInfoCache.get(mergeReduceArgs.getExecutorInfo());
 
         if (Objects.isNull(jobExecutorInfo)) {
-            throw new SnailJobMapReduceException("[{}]未发现", mergeReduceArgs.getExecutorInfo());
+            throw new SnailJobMapReduceException("[{}] not found", mergeReduceArgs.getExecutorInfo());
         }
 
         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());
         }
 
@@ -67,8 +69,9 @@ public class AnnotationMapReduceJobExecutor extends AbstractMapReduceExecutor {
                 jobExecutorInfo.getExecutor(), mergeReduceArgs);
         }
 
-        throw new SnailJobMapReduceException("[{}]未发现MergeReduceTask执行方法 [{}]",
+        throw new SnailJobMapReduceException("[{}] MergeReduceTask execution method not found [{}]",
             mergeReduceArgs.getExecutorInfo());
+
     }
 
     @Override