diff --git a/pom.xml b/pom.xml index 7809709..f5ca18e 100644 --- a/pom.xml +++ b/pom.xml @@ -3,7 +3,7 @@ 4.0.0 logstash-forwarder-java logstash-forwarder-java - 0.2.4 + 0.2.5-FIX-ISSUE-21 logstash-forwarder-java Java version of logstash forwarder https://github.com/didfet/logstash-forwarder-java diff --git a/src/main/java/info/fetter/logstashforwarder/FileWatcher.java b/src/main/java/info/fetter/logstashforwarder/FileWatcher.java index b50b7b4..b54a783 100644 --- a/src/main/java/info/fetter/logstashforwarder/FileWatcher.java +++ b/src/main/java/info/fetter/logstashforwarder/FileWatcher.java @@ -325,6 +325,7 @@ public class FileWatcher { List markedList = null; for(File file : oldWatchMap.keySet()) { FileState state = oldWatchMap.get(file); + state.setMatchedToNewFile(false); if(state.getRandomAccessFile() == null) { state.setDeleted(); }