diff --git a/src/modules/judge/judge/judge.go b/src/modules/judge/judge/judge.go index dc4cbafe..ab3623be 100644 --- a/src/modules/judge/judge/judge.go +++ b/src/modules/judge/judge/judge.go @@ -309,8 +309,8 @@ func GetReqs(stra *model.Stra, metric string, endpoints []string, now int64) ([] Endpoint: index.Endpoint, Metric: index.Metric, Tag: "", - Step: index.Step, - Dstype: index.Dstype, + Step: 10, + Dstype: "GAUGE", TS: now, } lostSeries = append(lostSeries, s) diff --git a/src/modules/judge/judge/nodata.go b/src/modules/judge/judge/nodata.go index 2e74e651..fd30e5d5 100644 --- a/src/modules/judge/judge/nodata.go +++ b/src/modules/judge/judge/nodata.go @@ -47,6 +47,7 @@ func nodataJudge() { Tags: "", TagsMap: map[string]string{}, DsType: "GAUGE", + Step: 10, } nodataJob.Acquire() diff --git a/src/modules/transfer/backend/query.go b/src/modules/transfer/backend/query.go index fd5ca775..3d91e634 100644 --- a/src/modules/transfer/backend/query.go +++ b/src/modules/transfer/backend/query.go @@ -178,6 +178,9 @@ func fetchDataSync(start, end int64, consolFun, endpoint, counter string, step i if err != nil { logger.Warningf("fetch tsdb data error: %+v", err) stats.Counter.Set("query.data.err", 1) + data.Endpoint = endpoint + data.Counter = counter + data.Step = step } dataChan <- data }