From 9f81450b38ccd2139f58a440d8d5718d4e434ac2 Mon Sep 17 00:00:00 2001 From: Aliaksandr Valialkin Date: Mon, 4 Mar 2024 19:37:58 +0200 Subject: [PATCH] lib/streamaggr: add missing "s" suffix in the warning message when the de-duplication or aggregation couldnt be finished in a timely manner --- lib/streamaggr/streamaggr.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/lib/streamaggr/streamaggr.go b/lib/streamaggr/streamaggr.go index 76fd4aa28..df08bc065 100644 --- a/lib/streamaggr/streamaggr.go +++ b/lib/streamaggr/streamaggr.go @@ -676,7 +676,7 @@ func (a *aggregator) dedupFlush(dedupInterval time.Duration) { a.dedupFlushDuration.Update(d.Seconds()) if d > dedupInterval { 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; "+ "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()) if d > interval { 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; "+ "reduce samples' ingestion rate to stream aggregation", interval, d.Seconds()) }