From a3bf7a16adf3279d0991f46958ae3d0001c6cbba Mon Sep 17 00:00:00 2001 From: liugq Date: Mon, 18 Jul 2022 20:25:51 +0800 Subject: [PATCH] fixed agg rate bug --- service/alerting/elasticsearch/engine.go | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/service/alerting/elasticsearch/engine.go b/service/alerting/elasticsearch/engine.go index 429f7d2b..53a15d0a 100644 --- a/service/alerting/elasticsearch/engine.go +++ b/service/alerting/elasticsearch/engine.go @@ -468,8 +468,12 @@ func (engine *Engine) GetTargetMetricData(rule *alerting.Rule, isFilterNaN bool, if len(k) == 20 { continue } + if len(v) < dataLength { + continue + } + //drop nil value bucket - if len(v[i]) < 2 { + if v == nil || len(v[i]) < 2 { continue DataLoop } if _, ok := v[i][1].(float64); !ok { @@ -478,6 +482,9 @@ func (engine *Engine) GetTargetMetricData(rule *alerting.Rule, isFilterNaN bool, parameters[k] = v[i][1] timestamp = v[i][0] } + if len(parameters) == 0 { + continue + } result, err := expression.Evaluate(parameters) if err != nil { return nil, queryResult, err