fix apache#3966 sub process doesnot send alert mail after process ins…

…tance ending. (apache#3972) Co-authored-by: baoliang <baoliang@analysys.com.cn>
lgcareer · Oct 22, 2020 · 7a088b7 · 7a088b7
1 parent ccc8ba1
commit 7a088b7
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...scheduler-server/src/main/java/org/apache/dolphinscheduler/server/utils/AlertManager.java b/...scheduler-server/src/main/java/org/apache/dolphinscheduler/server/utils/AlertManager.java
@@ -19,6 +19,7 @@
 
 import org.apache.dolphinscheduler.common.enums.AlertType;
 import org.apache.dolphinscheduler.common.enums.CommandType;
+import org.apache.dolphinscheduler.common.enums.Flag;
 import org.apache.dolphinscheduler.common.enums.ShowType;
 import org.apache.dolphinscheduler.common.enums.WarningType;
 import org.apache.dolphinscheduler.common.utils.DateUtils;
@@ -207,6 +208,9 @@ public void sendAlertWorkerToleranceFault(ProcessInstance processInstance, List<
      */
     public void sendAlertProcessInstance(ProcessInstance processInstance,
                                          List<TaskInstance> taskInstances){
+        if(Flag.YES == processInstance.getIsSubProcess()){
+            return;
+        }
 
         boolean sendWarnning = false;
         WarningType warningType = processInstance.getWarningType();