Remove metrics from the buffer on write (influxdata#5052)

otherpirate · Mar 15, 2019 · 4070667 · 4070667
1 parent a209827
commit 4070667
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/internal/models/buffer.go b/internal/models/buffer.go
@@ -175,9 +175,10 @@ func (b *Buffer) Accept(batch []telegraf.Metric) {
 		b.metricWritten(m)
 	}
 
-	if b.batchSize > 0 {
-		b.size -= b.batchSize
-		b.first += b.batchSize
+	b.size -= b.batchSize
+	for i := 0; i < b.batchSize; i++ {
+		b.buf[b.first] = nil
+		b.first++
 		b.first %= b.cap
 	}