diff --git a/service/alerting/elasticsearch/engine.go b/service/alerting/elasticsearch/engine.go
index fe2af3ab..65f1421b 100644
--- a/service/alerting/elasticsearch/engine.go
+++ b/service/alerting/elasticsearch/engine.go
@@ -750,6 +750,7 @@ func (engine *Engine) Do(rule *alerting.Rule) error {
 			Tags: rule.Tags,
 			Category: rule.Category,
 		}
+		alertMessage = msg
 		err = saveAlertMessage(msg)
 		if err != nil {
 			return fmt.Errorf("save alert message error: %w", err)