diff --git a/dolphinscheduler-alert/dolphinscheduler-alert-server/src/main/java/org/apache/dolphinscheduler/alert/AlertSenderService.java b/dolphinscheduler-alert/dolphinscheduler-alert-server/src/main/java/org/apache/dolphinscheduler/alert/AlertSenderService.java index d0c4b033da..fb8da102ff 100644 --- a/dolphinscheduler-alert/dolphinscheduler-alert-server/src/main/java/org/apache/dolphinscheduler/alert/AlertSenderService.java +++ b/dolphinscheduler-alert/dolphinscheduler-alert-server/src/main/java/org/apache/dolphinscheduler/alert/AlertSenderService.java @@ -255,10 +255,13 @@ public final class AlertSenderService extends Thread { } if (!sendWarning) { + String message = String.format( + "Alert Plugin %s send ignore warning type not match: plugin warning type is %s, alert data warning type is %s", + pluginInstanceName, warningType.getCode(), alertData.getWarnType()); logger.info( "Alert Plugin {} send ignore warning type not match: plugin warning type is {}, alert data warning type is {}", pluginInstanceName, warningType.getCode(), alertData.getWarnType()); - return null; + return new AlertResult("false", message); } AlertInfo alertInfo = AlertInfo.builder()