[dolphinscheduler] branch dev updated: fix Fault tolerance warning mapper add alert type to insert (#9533)

[ca...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

caishunfeng pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/dev by this push:
     new 1192fb8e12 fix Fault tolerance warning mapper add alert type to insert (#9533)
1192fb8e12 is described below

commit 1192fb8e12ce4a958c67cfc7b52450625290c160
Author: Tq <ti...@gmail.com>
AuthorDate: Sun Apr 17 10:17:00 2022 +0800

    fix Fault tolerance warning mapper add alert type to insert (#9533)
---
 .../resources/org/apache/dolphinscheduler/dao/mapper/AlertMapper.xml  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/AlertMapper.xml b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/AlertMapper.xml
index f0f514ab52..1e83b4965b 100644
--- a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/AlertMapper.xml
+++ b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/AlertMapper.xml
@@ -20,9 +20,9 @@
 <mapper namespace="org.apache.dolphinscheduler.dao.mapper.AlertMapper">
 
     <insert id="insertAlertWhenServerCrash">
-        insert into t_ds_alert(sign, title, content, alert_status, warning_type, log, alertgroup_id, create_time, update_time)
+        insert into t_ds_alert(sign, title, content, alert_status, warning_type, log, alertgroup_id, create_time, update_time, alert_type)
         SELECT #{alert.sign}, #{alert.title}, #{alert.content}, #{alert.alertStatus.code}, #{alert.warningType.code},
-               #{alert.log}, #{alert.alertGroupId}, #{alert.createTime}, #{alert.updateTime}
+               #{alert.log}, #{alert.alertGroupId}, #{alert.createTime}, #{alert.updateTime}, #{alert.alertType.code}
         from t_ds_alert
         where create_time >= #{crashAlarmSuppressionStartTime} and sign = #{alert.sign} and alert_status = #{alert.alertStatus.code}
         having count(*) = 0