From c4306577386248b175b59cdf5c0b2de0821d0291 Mon Sep 17 00:00:00 2001 From: yubo Date: Tue, 17 Nov 2020 22:08:32 +0800 Subject: [PATCH] transfer query end = end+1 (#406) --- src/modules/transfer/backend/m3db/query.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/modules/transfer/backend/m3db/query.go b/src/modules/transfer/backend/m3db/query.go index db2464d7..0392d7a3 100644 --- a/src/modules/transfer/backend/m3db/query.go +++ b/src/modules/transfer/backend/m3db/query.go @@ -22,7 +22,7 @@ func (cfg M3dbSection) queryDataOptions(inputs []dataobj.QueryData) (index.Query return index.Query{idx.NewDisjunctionQuery(q...)}, index.QueryOptions{ StartInclusive: time.Unix(inputs[0].Start, 0), - EndExclusive: time.Unix(inputs[0].End, 0), + EndExclusive: time.Unix(inputs[0].End+1, 0), SeriesLimit: cfg.SeriesLimit, DocsLimit: cfg.DocsLimit, } @@ -38,7 +38,7 @@ func (cfg M3dbSection) queryDataUIOptions(input dataobj.QueryDataForUI) (index.Q return index.Query{idx.NewConjunctionQuery(q1, q2, q3)}, index.QueryOptions{ StartInclusive: time.Unix(input.Start, 0), - EndExclusive: time.Unix(input.End, 0), + EndExclusive: time.Unix(input.End+1, 0), SeriesLimit: cfg.SeriesLimit, DocsLimit: cfg.DocsLimit, }