From 2d3ada1634a2f2d9df59a38cb83e4ab95ea8d4e2 Mon Sep 17 00:00:00 2001
From: opensnail <598092184@qq.com>
Date: Tue, 25 Jun 2024 18:24:31 +0800
Subject: [PATCH] =?UTF-8?q?feat(sj=5F1.1.0-beta2):=20=E6=A0=A1=E9=AA=8C?=
 =?UTF-8?q?=E9=9D=9EMap=E6=88=96=E8=80=85MapReduce=E4=BB=BB=E5=8A=A1?=
 =?UTF-8?q?=EF=BC=8C=20=E4=BD=BF=E7=94=A8AbstractMapExecutor=E5=BC=82?=
 =?UTF-8?q?=E5=B8=B8=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../client/job/core/executor/AbstractMapExecutor.java      | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/executor/AbstractMapExecutor.java b/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/executor/AbstractMapExecutor.java
index b4bae628f..22f523d07 100644
--- a/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/executor/AbstractMapExecutor.java
+++ b/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/executor/AbstractMapExecutor.java
@@ -35,8 +35,11 @@ public abstract class AbstractMapExecutor extends AbstractJobExecutor implements
 
     @Override
     protected ExecuteResult doJobExecute(final JobArgs jobArgs) {
-        MapArgs mapArgs = (MapArgs) jobArgs;
-        return this.doJobMapExecute(mapArgs);
+        if (jobArgs instanceof MapArgs) {
+            return this.doJobMapExecute((MapArgs) jobArgs);
+        }
+
+        throw new SnailJobMapReduceException("For tasks that are not of type map or map reduce, please do not use the AbstractMapExecutor class.");
     }
 
     public abstract ExecuteResult doJobMapExecute(MapArgs mapArgs);