You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by ke...@apache.org on 2022/12/07 02:30:14 UTC
[dolphinscheduler] 02/03: [Bug] [Alert] Ignore alert not write info to db (#12867)
This is an automated email from the ASF dual-hosted git repository.
kerwin pushed a commit to branch 3.1.2-prepare
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
commit 6e520fe8f74b7555b92c369942530fe094a5010c
Author: 旺阳 <qi...@cisco.com>
AuthorDate: Thu Nov 17 14:14:12 2022 +0800
[Bug] [Alert] Ignore alert not write info to db (#12867)
* add alert not match return info
---
.../java/org/apache/dolphinscheduler/alert/AlertSenderService.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
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 0063de0672..8a1f810d46 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
@@ -233,10 +233,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()