diff --git a/plugins/inputs/logparser/logparser.go b/plugins/inputs/logparser/logparser.go index a7fd97e8e..e724f2d4b 100644 --- a/plugins/inputs/logparser/logparser.go +++ b/plugins/inputs/logparser/logparser.go @@ -294,7 +294,6 @@ func (l *LogParserPlugin) Stop() { if err != nil { log.Printf("E! Error stopping tail on file %s\n", t.Filename) } - t.Cleanup() } close(l.done) l.wg.Wait() diff --git a/plugins/inputs/tail/tail.go b/plugins/inputs/tail/tail.go index bdfa2de44..834d7cf8f 100644 --- a/plugins/inputs/tail/tail.go +++ b/plugins/inputs/tail/tail.go @@ -9,7 +9,6 @@ import ( "sync" "github.com/influxdata/tail" - "github.com/influxdata/telegraf" "github.com/influxdata/telegraf/internal/globpath" "github.com/influxdata/telegraf/plugins/inputs" @@ -213,9 +212,6 @@ func (t *Tail) Stop() { } } - for _, tailer := range t.tailers { - tailer.Cleanup() - } t.wg.Wait() }