diff --git a/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/dto/MrTaskResult.java b/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/dto/MapArgs.java
similarity index 69%
rename from snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/dto/MrTaskResult.java
rename to snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/dto/MapArgs.java
index 6bce83b4..74f5c0d4 100644
--- a/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/dto/MrTaskResult.java
+++ b/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/dto/MapArgs.java
@@ -9,11 +9,11 @@ import lombok.Data;
  * @date : 2024-06-12 13:59
  */
 @Data
-public class MrTaskResult {
+public class MapArgs {
 
-    private String taskId;
+    private String mapName;
 
-    private boolean success;
+    private Boolean success;
 
     private String result;
 }
diff --git a/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/dto/MapReduceArgs.java b/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/dto/MapReduceArgs.java
index f29b83cb..4cead9a2 100644
--- a/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/dto/MapReduceArgs.java
+++ b/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/dto/MapReduceArgs.java
@@ -3,6 +3,8 @@ package com.aizuda.snailjob.client.job.core.dto;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
 
+import java.util.List;
+
 /**
  * @author: opensnail
  * @date : 2024-06-13
@@ -13,4 +15,6 @@ import lombok.EqualsAndHashCode;
 public class MapReduceArgs extends JobArgs {
 
     private String mapName;
+
+    private List<MapArgs> mapArgsList;
 }
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 2ba2dc63..238fe9f8 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
@@ -11,7 +11,6 @@ import com.aizuda.snailjob.client.model.request.MapTaskRequest;
 import com.aizuda.snailjob.common.core.constant.SystemConstants;
 import com.aizuda.snailjob.common.core.exception.SnailJobMapReduceException;
 import com.aizuda.snailjob.common.core.model.JobContext;
-import com.aizuda.snailjob.common.core.model.MapContext;
 import com.aizuda.snailjob.common.core.model.NettyResult;
 import com.aizuda.snailjob.common.core.model.Result;
 import lombok.extern.slf4j.Slf4j;
@@ -35,7 +34,7 @@ public abstract class AbstractMapExecutor extends AbstractJobExecutor implements
     @Override
     protected ExecuteResult doJobExecute(final JobArgs jobArgs) {
         MapReduceArgs mapReduceArgs = (MapReduceArgs) jobArgs;
-        return doJobExecute(mapReduceArgs);
+        return this.doJobExecute(mapReduceArgs);
     }
 
     public abstract ExecuteResult doJobExecute(MapReduceArgs mapReduceArgs);
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 c8089391..a41b7cb1 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,9 +1,11 @@
 package com.aizuda.snailjob.client.job.core.executor;
 
-import com.aizuda.snailjob.client.job.core.dto.JobArgs;
+import com.aizuda.snailjob.client.job.core.dto.MapArgs;
 import com.aizuda.snailjob.client.model.ExecuteResult;
 import com.aizuda.snailjob.common.core.model.JobContext;
 
+import java.util.List;
+
 /**
  * @author zhengweilin
  * @version 1.0.0
@@ -11,5 +13,5 @@ import com.aizuda.snailjob.common.core.model.JobContext;
  */
 public abstract class AbstractMapReduceExecutor extends AbstractMapExecutor {
 
-    protected abstract ExecuteResult doReduceExecute(JobContext jobContext, JobArgs jobArgs);
+    protected abstract ExecuteResult doReduceExecute(JobContext jobContext, List<MapArgs> mapArgsList);
 }
diff --git a/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/model/response/JobBatchResponseVO.java b/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/model/response/JobBatchResponseVO.java
index f701558b..dbdfbc36 100644
--- a/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/model/response/JobBatchResponseVO.java
+++ b/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/model/response/JobBatchResponseVO.java
@@ -26,6 +26,11 @@ public class JobBatchResponseVO {
      */
     private String jobName;
 
+    /**
+     * 任务类型
+     */
+    private String taskType;
+
     /**
      * 工作流节点名称
      */