github-mirrors/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2025-02-09 15:27:11 +00:00
Code Issues Projects Releases Packages Wiki Activity

lib/streamaggr: add missing "s" suffix in the warning message when the de-duplication or aggregation couldnt be finished in a timely manner

Browse source
This commit is contained in:
Aliaksandr Valialkin 2024-03-04 19:37:58 +02:00
parent d10932bd99
commit 9f81450b38
No known key found for this signature in database
GPG key ID: 52C003EE2BCDB9EB
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
lib/streamaggr/streamaggr.go
View file

@ -676,7 +676,7 @@ func (a *aggregator) dedupFlush(dedupInterval time.Duration) {
a.dedupFlushDuration.Update(d.Seconds()) a.dedupFlushDuration.Update(d.Seconds())
if d > dedupInterval { if d > dedupInterval {
a.dedupFlushTimeouts.Inc() a.dedupFlushTimeouts.Inc()
logger.Warnf("deduplication couldn't be finished in the configured dedup_interval=%s; it took %.03f; "+ logger.Warnf("deduplication couldn't be finished in the configured dedup_interval=%s; it took %.03fs; "+
"possible solutions: increase dedup_interval; use match filter matching smaller number of series; "+ "possible solutions: increase dedup_interval; use match filter matching smaller number of series; "+
"reduce samples' ingestion rate to stream aggregation", dedupInterval, d.Seconds()) "reduce samples' ingestion rate to stream aggregation", dedupInterval, d.Seconds())
} }
@ -708,7 +708,7 @@ func (a *aggregator) flush(pushFunc PushFunc, interval time.Duration, resetState
a.flushDuration.Update(d.Seconds()) a.flushDuration.Update(d.Seconds())
if d > interval { if d > interval {
a.flushTimeouts.Inc() a.flushTimeouts.Inc()
logger.Warnf("stream aggregation couldn't be finished in the configured interval=%s; it took %.03f; "+ logger.Warnf("stream aggregation couldn't be finished in the configured interval=%s; it took %.03fs; "+
"possible solutions: increase interval; use match filter matching smaller number of series; "+ "possible solutions: increase interval; use match filter matching smaller number of series; "+
"reduce samples' ingestion rate to stream aggregation", interval, d.Seconds()) "reduce samples' ingestion rate to stream aggregation", interval, d.Seconds())
} }