From debd4093758378a1032fa1b9613a7d9b9776cdab Mon Sep 17 00:00:00 2001 From: Paul Friel Date: Mon, 11 Sep 2017 16:17:22 -0500 Subject: [PATCH] Fix fluentd buffer, retry fields --- plugins/inputs/fluentd/fluentd.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/plugins/inputs/fluentd/fluentd.go b/plugins/inputs/fluentd/fluentd.go index ba8dba802bf96..c999607403ea7 100644 --- a/plugins/inputs/fluentd/fluentd.go +++ b/plugins/inputs/fluentd/fluentd.go @@ -148,15 +148,15 @@ func (h *Fluentd) Gather(acc telegraf.Accumulator) error { } if p.BufferQueueLength != nil { - tmpFields["buffer_queue_length"] = p.BufferQueueLength + tmpFields["buffer_queue_length"] = *p.BufferQueueLength } if p.RetryCount != nil { - tmpFields["retry_count"] = p.RetryCount + tmpFields["retry_count"] = *p.RetryCount } if p.BufferTotalQueuedSize != nil { - tmpFields["buffer_total_queued_size"] = p.BufferTotalQueuedSize + tmpFields["buffer_total_queued_size"] = *p.BufferTotalQueuedSize } if !((p.BufferQueueLength == nil) && (p.RetryCount == nil) && (p.BufferTotalQueuedSize == nil)) {