diff --git a/snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/result/job/MapReduceJobExecutorHandler.java b/snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/result/job/MapReduceJobExecutorHandler.java
index 30287b70..105b5e26 100644
--- a/snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/result/job/MapReduceJobExecutorHandler.java
+++ b/snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/result/job/MapReduceJobExecutorHandler.java
@@ -123,4 +123,12 @@ public class MapReduceJobExecutorHandler extends AbstractJobExecutorResultHandle
         return false;
     }
 
+    @Override
+    protected void openNextWorkflowNode(JobExecutorResultContext context) {
+        if (context.isCreateReduceTask()){
+            // 任务暂未完成，无需开启后续节点；更新上下文
+            return;
+        }
+        super.openNextWorkflowNode(context);
+    }
 }
diff --git a/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/WorkflowNodeServiceImpl.java b/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/WorkflowNodeServiceImpl.java
index e78976c2..e09ce1a7 100644
--- a/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/WorkflowNodeServiceImpl.java
+++ b/snail-job-server/snail-job-server-web/src/main/java/com/aizuda/snailjob/server/web/service/impl/WorkflowNodeServiceImpl.java
@@ -52,14 +52,6 @@ public class WorkflowNodeServiceImpl implements WorkflowNodeService {
             jobHandler.stop(jobTaskBatch.getId());
         }
 
-        // 继续执行后续的任务
-        WorkflowNodeTaskExecuteDTO taskExecuteDTO = new WorkflowNodeTaskExecuteDTO();
-        taskExecuteDTO.setWorkflowTaskBatchId(workflowTaskBatchId);
-        taskExecuteDTO.setTaskExecutorScene(JobTaskExecutorSceneEnum.MANUAL_WORKFLOW.getType());
-        taskExecuteDTO.setParentId(nodeId);
-
-        workflowBatchHandler.openNextNode(taskExecuteDTO);
-
         return Boolean.TRUE;
     }