update

escheduler-server/src/main/java/cn/escheduler/server/master/runner/MasterExecThread.java

@@ -432,6 +432,9 @@ public class MasterExecThread implements Runnable {
         }
 
         for (String nodeName : startVertex){
+            if(completeTaskList.containsKey(nodeName)){
+                continue;
+            }
             // encapsulation task instance
             TaskInstance taskInstance = createTaskInstance(processInstance, nodeName ,
                     dag.getNode(nodeName),parentNodeName);

escheduler-server/src/main/java/cn/escheduler/server/zk/ZKMasterClient.java

@@ -136,6 +136,7 @@ public class ZKMasterClient extends AbstractZKClient {
 
 			// check if fault tolerance is required，failure and tolerance
 			if (getActiveMasterNum() == 1) {
+				failoverWorker(null, true);
 //				processDao.masterStartupFaultTolerant();
 				failoverMaster(null);
 			}

escheduler-server/src/test/java/cn/escheduler/server/master/MasterCommandTest.java

@@ -38,6 +38,7 @@ import org.slf4j.LoggerFactory;
 
 import java.util.ArrayList;
 import java.util.Collection;
+import java.util.Map;
 
 /**
  *  master test
@@ -135,6 +136,8 @@ public class MasterCommandTest {
 
             System.out.println(start.toString());
 
+            Map<String, TaskNode> forbidden = DagHelper.getForbiddenTaskNodeMaps(processDefinition.getProcessDefinitionJson());
+            System.out.println(forbidden);
         } catch (Exception e) {
             e.printStackTrace();
         }