Remove tail cleanup call to avoid double decrement (#6089)
This commit is contained in:
@@ -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()
|
||||
|
||||
@@ -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()
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user