From b41276c27aba8985b98b6d73541b8d9cb1d87cf7 Mon Sep 17 00:00:00 2001 From: treff7es Date: Tue, 19 Jul 2016 14:09:22 +0200 Subject: [PATCH] Fix for fail to remove state where file was deleted and clean_removed was set. --- filebeat/prospector/prospector_log.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/filebeat/prospector/prospector_log.go b/filebeat/prospector/prospector_log.go index 5496f37e891..8bbb7fb2758 100644 --- a/filebeat/prospector/prospector_log.go +++ b/filebeat/prospector/prospector_log.go @@ -52,7 +52,7 @@ func (p *ProspectorLog) Run() { p.scan() // It is important that a first scan is run before cleanup to make sure all new states are read first - if p.config.CleanInactive > 0 { + if p.config.CleanInactive > 0 || p.config.CleanRemoved { p.Prospector.states.Cleanup() logp.Debug("prospector", "Prospector states cleaned up.") }