diff --git a/sinks/influxSink.go b/sinks/influxSink.go index 212647d..78dda56 100644 --- a/sinks/influxSink.go +++ b/sinks/influxSink.go @@ -142,17 +142,20 @@ func (s *InfluxSink) Flush() error { // Send metrics from batch slice err := s.writeApi.WritePoint(context.Background(), s.batch...) - if err != nil { - cclog.ComponentError(s.name, "flush failed:", err.Error()) - return err - } // Clear batch slice + // (when sending the metrics failed, metrics get dropped and are lost) for i := range s.batch { s.batch[i] = nil } s.batch = s.batch[:0] + // Report errors for sending metrics + if err != nil { + cclog.ComponentError(s.name, "flush failed:", err.Error()) + return err + } + return nil }