diff --git a/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/alert/ProcessAlertManager.java b/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/alert/ProcessAlertManager.java index 9296aebe2716fef86c214044966e1cb4e87c9297..5efac48bdcd697e9d324665aba2f1e0ca2c3baa9 100644 --- a/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/alert/ProcessAlertManager.java +++ b/dolphinscheduler-service/src/main/java/org/apache/dolphinscheduler/service/alert/ProcessAlertManager.java @@ -283,6 +283,10 @@ public class ProcessAlertManager { // no need to close alert return; } + if (processInstance.getWarningGroupId() == null || processInstance.getWarningGroupId() == 0) { + // no need to close alert if not close alert + return; + } Alert alert = new Alert(); alert.setAlertGroupId(processInstance.getWarningGroupId());