From 7df4fe3faa50fc8b3c6d5b4209a5b1a107497cb4 Mon Sep 17 00:00:00 2001 From: helenxu1221 Date: Sun, 9 Feb 2020 22:51:21 -0500 Subject: [PATCH] reset counter after collecting metric (#6798) Signed-off-by: HelenXu --- storage/remote/queue_manager.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/storage/remote/queue_manager.go b/storage/remote/queue_manager.go index 2dd906774..a4384e03e 100644 --- a/storage/remote/queue_manager.go +++ b/storage/remote/queue_manager.go @@ -825,8 +825,8 @@ func (s *shards) runShard(ctx context.Context, shardID int, queue chan sample) { if nPending > 0 { level.Debug(s.qm.logger).Log("msg", "runShard timer ticked, sending samples", "samples", nPending, "shard", shardNum) s.sendSamples(ctx, pendingSamples[:nPending], &buf) - nPending = 0 s.qm.pendingSamplesMetric.Sub(float64(nPending)) + nPending = 0 } timer.Reset(time.Duration(s.qm.cfg.BatchSendDeadline)) }