lib/streamaggr: added aggregation windows

This commit is contained in:
AndrewChubatiuk 2024-06-12 14:54:28 +03:00
parent 129b2236ef
commit aca33307a9
No known key found for this signature in database
GPG key ID: 96D776CC99880667

View file

@ -154,7 +154,6 @@ func (as *rateAggrState) flushState(ctx *flushCtx, flushTimestamp int64, idx int
state.lastValues[idx] = rateLastValueState{}
sv.state[k1] = state
}
sv.mu.Unlock()
if as.suffix == "rate_avg" && totalItems > 0 {