From 56227db85095e72d12784f5cc4544e71390566ad Mon Sep 17 00:00:00 2001 From: liugq Date: Wed, 27 Apr 2022 11:03:17 +0800 Subject: [PATCH] update read kv last notification time --- service/alerting/elasticsearch/engine.go | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/service/alerting/elasticsearch/engine.go b/service/alerting/elasticsearch/engine.go index fc600a0e..56c331a1 100644 --- a/service/alerting/elasticsearch/engine.go +++ b/service/alerting/elasticsearch/engine.go @@ -583,9 +583,12 @@ func (engine *Engine) Do(rule *alerting.Rule) error { if err != nil { return fmt.Errorf("get last notification time from kv error: %w", err) } - rule.LastNotificationTime, err = time.ParseInLocation(time.RFC3339, string(timeBytes), time.UTC) - if err != nil { - return fmt.Errorf("parse last notification time from kv error: %w", err) + timeStr := string(timeBytes) + if timeStr != ""{ + rule.LastNotificationTime, err = time.ParseInLocation(time.RFC3339, string(timeBytes), time.UTC) + if err != nil { + return fmt.Errorf("parse last notification time from kv error: %w", err) + } } } period := time.Now().Sub(rule.LastNotificationTime.Local())