From 7325636d8f2d6d9506f7c2b29ea7c232feee6444 Mon Sep 17 00:00:00 2001 From: dhb52 Date: Fri, 13 Sep 2024 14:43:49 +0800 Subject: [PATCH] =?UTF-8?q?feat(sj=5F1.2.0-beta2):=20=E5=A2=9E=E5=8A=A0?= =?UTF-8?q?=E4=BB=BB=E5=8A=A1=E4=BB=BB=E5=8A=A1=E7=B1=BB=E5=9E=8BMapReduce?= =?UTF-8?q?=E6=A0=A1=E9=AA=8C?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../client/job/core/executor/AbstractMapReduceExecutor.java | 2 ++ 1 file changed, 2 insertions(+) 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())) {