Loading dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterExecThread.java +3 −3 Original line number Diff line number Diff line Loading @@ -224,14 +224,14 @@ public class MasterExecThread implements Runnable { // execute process ,waiting for end runProcess(); // process instace failure ,no more complements // process instace failure ,no more complements if(!processInstance.getState().typeIsSuccess()){ logger.info("process {} state {}, complement not completely!", processInstance.getId(), processInstance.getState()); break; } // current process instance sucess ,next execute // current process instance success ,next execute scheduleDate = DateUtils.getSomeDay(scheduleDate, 1); if(scheduleDate.after(endDate)){ // all success Loading Loading @@ -541,7 +541,7 @@ public class MasterExecThread implements Runnable { private DependResult isTaskDepsComplete(String taskName) { Collection<String> startNodes = dag.getBeginNode(); // ff the vertex returns true directly // if the vertex returns true directly if(startNodes.contains(taskName)){ return DependResult.SUCCESS; } Loading Loading
dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterExecThread.java +3 −3 Original line number Diff line number Diff line Loading @@ -224,14 +224,14 @@ public class MasterExecThread implements Runnable { // execute process ,waiting for end runProcess(); // process instace failure ,no more complements // process instace failure ,no more complements if(!processInstance.getState().typeIsSuccess()){ logger.info("process {} state {}, complement not completely!", processInstance.getId(), processInstance.getState()); break; } // current process instance sucess ,next execute // current process instance success ,next execute scheduleDate = DateUtils.getSomeDay(scheduleDate, 1); if(scheduleDate.after(endDate)){ // all success Loading Loading @@ -541,7 +541,7 @@ public class MasterExecThread implements Runnable { private DependResult isTaskDepsComplete(String taskName) { Collection<String> startNodes = dag.getBeginNode(); // ff the vertex returns true directly // if the vertex returns true directly if(startNodes.contains(taskName)){ return DependResult.SUCCESS; } Loading