add reader close to Stop()

open-telemetry · Jun 7, 2021 · e9112de · e9112de
1 parent 2d49e7c
commit e9112de
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/operator/builtin/input/file/file.go b/operator/builtin/input/file/file.go
@@ -87,6 +87,12 @@ func (f *InputOperator) Start(persister operator.Persister) error {
 func (f *InputOperator) Stop() error {
 	f.cancel()
 	f.wg.Wait()
+	for _, reader := range f.lastPollReaders {
+		reader.Close()
+	}
+	for _, reader := range f.knownFiles {
+		reader.Close()
+	}
 	f.knownFiles = nil
 	f.cancel = nil
 	return nil