diff --git a/pkg/logql/engine.go b/pkg/logql/engine.go index 294fe81457de..23c3073fb728 100644 --- a/pkg/logql/engine.go +++ b/pkg/logql/engine.go @@ -5,7 +5,6 @@ import ( "errors" "flag" "fmt" - "math" "sort" "strconv" "strings" @@ -444,11 +443,6 @@ func (q *query) JoinSampleVector(next bool, r StepResult, stepEvaluator StepEval return vec, nil } - stepCount := int(math.Ceil(float64(q.params.End().Sub(q.params.Start()).Nanoseconds()) / float64(q.params.Step().Nanoseconds()))) - if stepCount <= 0 { - stepCount = 1 - } - for next { vec = r.SampleVector() vectorsToSeries(vec, seriesIndex)