From 6ea71e1edeb4d36f82fe6911bb8744a7c622eae2 Mon Sep 17 00:00:00 2001
From: baoliang <baoliang@analysys.com.cn>
Date: Tue, 21 May 2019 13:35:35 +0800
Subject: [PATCH]  add tolerance tasks when start failure task

---
 escheduler-dao/src/main/java/cn/escheduler/dao/ProcessDao.java | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/escheduler-dao/src/main/java/cn/escheduler/dao/ProcessDao.java b/escheduler-dao/src/main/java/cn/escheduler/dao/ProcessDao.java
index 0eb65dbe14..f8182d692c 100644
--- a/escheduler-dao/src/main/java/cn/escheduler/dao/ProcessDao.java
+++ b/escheduler-dao/src/main/java/cn/escheduler/dao/ProcessDao.java
@@ -588,10 +588,12 @@ public class ProcessDao extends AbstractBaseDao {
             case START_FAILURE_TASK_PROCESS:
                 // find failed tasks and init these tasks
                 List<Integer> failedList = this.findTaskIdByInstanceState(processInstance.getId(), ExecutionStatus.FAILURE);
+                List<Integer> toleranceList = this.findTaskIdByInstanceState(processInstance.getId(), ExecutionStatus.NEED_FAULT_TOLERANCE);
                 List<Integer> killedList = this.findTaskIdByInstanceState(processInstance.getId(), ExecutionStatus.KILL);
                 cmdParam.remove(Constants.CMDPARAM_RECOVERY_START_NODE_STRING);
 
                 failedList.addAll(killedList);
+                failedList.addAll(toleranceList);
                 for(Integer taskId : failedList){
                     initTaskInstance(this.findTaskInstanceById(taskId));
                 }