diff --git a/filter/matched_metrics/metrics.go b/filter/matched_metrics/metrics.go index c3a3f9508..5de457ba6 100644 --- a/filter/matched_metrics/metrics.go +++ b/filter/matched_metrics/metrics.go @@ -88,7 +88,7 @@ func (matcher *MetricsMatcher) receiveBatch(metrics <-chan *moira.MatchedMetric) case <-batchTimer.C: batchedMetrics <- batch } - batchTimer.Reset(time.Second) + batchTimer.Reset(matcher.batchForcedSaveTimeout) } }() return batchedMetrics