diff --git a/pkg/util/log/fluent_client.go b/pkg/util/log/fluent_client.go index 84c746429665..c49f6e2ab398 100644 --- a/pkg/util/log/fluent_client.go +++ b/pkg/util/log/fluent_client.go @@ -74,6 +74,7 @@ func (l *fluentSink) output(b []byte, opts sinkOutputOptions) (err error) { } if err := l.ensureConnLocked(b); err != nil { + logging.metrics.IncrementCounter(FluentSinkConnectionError, 1) return err } return l.tryWriteLocked(b)