From b4e0a6e20683253abe021acb9048602abc250668 Mon Sep 17 00:00:00 2001 From: Koji Kawamura Date: Wed, 19 Jul 2017 22:18:17 +0900 Subject: [PATCH] NIFI-4205: Avoid duplicated data from TailFile Before this fix, it is possible that TailFile to produce duplicated data if an already tailed file has newer timestamp and fewer or the same amout of data. Signed-off-by: Pierre Villard This closes #2021. --- .../java/org/apache/nifi/processors/standard/TailFile.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/TailFile.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/TailFile.java index e2f75bcae7..f5d340961f 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/TailFile.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/TailFile.java @@ -689,8 +689,7 @@ public class TailFile extends AbstractProcessor { // Check if file has rotated if (rolloverOccurred - || (timestamp <= file.lastModified() && length > file.length()) - || (timestamp < file.lastModified() && length >= file.length())) { + || (timestamp <= file.lastModified() && length > file.length())) { // Since file has rotated, we close the reader, create a new one, and then reset our state. try {