Merge pull request #3947 from lenboo/133-fault

[FIX-3615] master exit gracefully
4 years ago · 4f94943b2d
1 changed files with 1 additions and 1 deletions
--- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterExecThread.java
+++ b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterExecThread.java
@ -973,7 +973,7 @@ public class MasterExecThread implements Runnable {
        // submit start node
        submitPostNode(null);
        boolean sendTimeWarning = false;
-        while(!processInstance.isProcessInstanceStop()){
+        while(!processInstance.isProcessInstanceStop() && Stopper.isRunning()){
            // send warning email if process time out.
            if(!sendTimeWarning && checkProcessTimeOut(processInstance) ){