From 10da0b5ca4a1a719ec1ae365a479859e168941d7 Mon Sep 17 00:00:00 2001 From: Eugen Biegler Date: Fri, 14 Dec 2018 18:37:48 +0100 Subject: [PATCH] Add line length to batchSize Signed-off-by: Eugen Biegler --- pkg/promtail/client.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/pkg/promtail/client.go b/pkg/promtail/client.go index 69e10ec45f20..8919d5c63ce1 100644 --- a/pkg/promtail/client.go +++ b/pkg/promtail/client.go @@ -109,9 +109,11 @@ func (c *Client) run() { if err := c.send(batch); err != nil { level.Error(c.logger).Log("msg", "error sending batch", "error", err) } + batchSize = 0 batch = map[model.Fingerprint]*logproto.Stream{} } + batchSize += len(e.Line) fp := e.labels.FastFingerprint() stream, ok := batch[fp] if !ok {