diff --git a/storage/metric/tiered.go b/storage/metric/tiered.go index b352612cb..aba2511b8 100644 --- a/storage/metric/tiered.go +++ b/storage/metric/tiered.go @@ -269,17 +269,17 @@ func (t *TieredStorage) flushMemory(ttl time.Duration) { queueLength := len(t.appendToDiskQueue) if queueLength > 0 { - log.Printf("Writing %d samples ...", queueLength) samples := model.Samples{} for i := 0; i < queueLength; i++ { chunk := <-t.appendToDiskQueue samples = append(samples, chunk...) } + log.Printf("Writing %d samples...", len(samples)) t.DiskStorage.AppendSamples(samples) } - log.Println("Done flushing...") + log.Println("Done flushing.") } func (t *TieredStorage) Close() {