diff --git a/pkg/acquisition/file_reader.go b/pkg/acquisition/file_reader.go index ecb41711f..ea704bd0b 100644 --- a/pkg/acquisition/file_reader.go +++ b/pkg/acquisition/file_reader.go @@ -238,6 +238,9 @@ LOOP: select { case <-AcquisTomb.Dying(): //we are being killed by main clog.Infof("Killing acquistion routine") + if err := ctx.tail.Stop(); err != nil { + clog.Warningf("error in stop : %s", err) + } break LOOP case <-ctx.tail.Tomb.Dying(): //our tailer is dying clog.Warningf("Reader is dying/dead")