diff --git a/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/executor/AbstractMapReduceExecutor.java b/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/executor/AbstractMapReduceExecutor.java
index 546ecd18e..5b05b5c53 100644
--- a/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/executor/AbstractMapReduceExecutor.java
+++ b/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/executor/AbstractMapReduceExecutor.java
@@ -1,5 +1,6 @@
 package com.aizuda.snailjob.client.job.core.executor;
 
+import cn.hutool.core.lang.Assert;
 import com.aizuda.snailjob.client.job.core.dto.JobArgs;
 import com.aizuda.snailjob.client.job.core.dto.MergeReduceArgs;
 import com.aizuda.snailjob.client.job.core.dto.ReduceArgs;
@@ -18,6 +19,7 @@ public abstract class AbstractMapReduceExecutor extends AbstractMapExecutor {
     @Override
     public ExecuteResult doJobExecute(final JobArgs jobArgs) {
         JobContext jobContext = JobContextManager.getJobContext();
+        Assert.notNull(jobContext.getMrStage(), "请确认服务器当前定时任务的[任务类型]为MapReduce");
         if (jobContext.getMrStage().equals(MapReduceStageEnum.MAP.getStage())) {
             return super.doJobExecute(jobArgs);
         } else if (jobContext.getMrStage().equals(MapReduceStageEnum.REDUCE.getStage())) {