We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a233af2 commit a44681dCopy full SHA for a44681d
plugins/inputs/logparser/logparser.go
@@ -294,7 +294,6 @@ func (l *LogParserPlugin) Stop() {
294
if err != nil {
295
log.Printf("E! Error stopping tail on file %s\n", t.Filename)
296
}
297
- t.Cleanup()
298
299
close(l.done)
300
l.wg.Wait()
plugins/inputs/tail/tail.go
@@ -9,7 +9,6 @@ import (
9
"sync"
10
11
"github.com/influxdata/tail"
12
-
13
"github.com/influxdata/telegraf"
14
"github.com/influxdata/telegraf/internal/globpath"
15
"github.com/influxdata/telegraf/plugins/inputs"
@@ -213,9 +212,6 @@ func (t *Tail) Stop() {
213
212
214
215
216
- for _, tailer := range t.tailers {
217
- tailer.Cleanup()
218
- }
219
t.wg.Wait()
220
221
0 commit comments