diff --git a/app/vmalert/remotewrite/remotewrite.go b/app/vmalert/remotewrite/remotewrite.go index acb919ceb..f508fded7 100644 --- a/app/vmalert/remotewrite/remotewrite.go +++ b/app/vmalert/remotewrite/remotewrite.go @@ -95,6 +95,7 @@ func NewClient(ctx context.Context, cfg Config) (*Client, error) { baPass: cfg.BasicAuthPass, flushInterval: cfg.FlushInterval, maxBatchSize: cfg.MaxBatchSize, + maxQueueSize: cfg.MaxQueueSize, doneCh: make(chan struct{}), input: make(chan prompbmarshal.TimeSeries, cfg.MaxQueueSize), }