소스 검색

elasticsearch: query interval override fix

Marcus Efraimsson 7 년 전
부모
커밋
4436b8da12
2개의 변경된 파일2개의 추가작업 그리고 2개의 파일을 삭제
  1. 1 1
      pkg/tsdb/elasticsearch/client/client.go
  2. 1 1
      pkg/tsdb/elasticsearch/time_series_query.go

+ 1 - 1
pkg/tsdb/elasticsearch/client/client.go

@@ -104,7 +104,7 @@ func (c *baseClientImpl) GetTimeField() string {
 }
 
 func (c *baseClientImpl) GetMinInterval(queryInterval string) (time.Duration, error) {
-	return tsdb.GetIntervalFrom(c.ds, simplejson.NewFromAny(map[string]string{
+	return tsdb.GetIntervalFrom(c.ds, simplejson.NewFromAny(map[string]interface{}{
 		"interval": queryInterval,
 	}), 5*time.Second)
 }

+ 1 - 1
pkg/tsdb/elasticsearch/time_series_query.go

@@ -258,7 +258,7 @@ func (p *timeSeriesQueryParser) parse(tsdbQuery *tsdb.TsdbQuery) ([]*Query, erro
 			return nil, err
 		}
 		alias := model.Get("alias").MustString("")
-		interval := model.Get("interval").MustString()
+		interval := strconv.FormatInt(q.IntervalMs, 10) + "ms"
 
 		queries = append(queries, &Query{
 			TimeField:  timeField,