From 584215b1863927bb25520857acc3b090d9f40bf9 Mon Sep 17 00:00:00 2001 From: Ankit Nayan Date: Mon, 26 Apr 2021 23:19:34 +0530 Subject: [PATCH] fixed NaN response from Druid during span aggregates results --- pkg/query-service/druidQuery/query.go | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) diff --git a/pkg/query-service/druidQuery/query.go b/pkg/query-service/druidQuery/query.go index 0c632f0028..c0db769722 100644 --- a/pkg/query-service/druidQuery/query.go +++ b/pkg/query-service/druidQuery/query.go @@ -254,19 +254,18 @@ func SearchSpansAggregate(client *godruid.Client, queryParams *model.SpanSearchA return nil, clientErr } - // fmt.Println("response", client.LastResponse) + fmt.Println("response", client.LastResponse) - reveivedResponse := new([]SpanSearchAggregatesDuratonReceivedItem) - - err = json.Unmarshal([]byte(client.LastResponse), reveivedResponse) - if err != nil { + receivedResponse := new([]SpanSearchAggregatesDuratonReceivedItem) + err = json.Unmarshal([]byte(client.LastResponse), receivedResponse) + if err != nil && len(*receivedResponse) == 0 { zap.S().Error(err) return nil, fmt.Errorf("Error in unmarshalling response from druid") } var response []SpanSearchAggregatesResponseItem - for _, elem := range *reveivedResponse { + for _, elem := range *receivedResponse { value := elem.Result.Value timeObj, _ := time.Parse(time.RFC3339Nano, elem.Timestamp)