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 b4bae628..22f523d0 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);