commit 832c55ccb74cce73c054d918bb6380c96eb5ed94
author Arpad Boda <aboda@apache.org> Sun Aug 23 22:27:24 2020 +0200
committer Marton Szasz <szaszm01@gmail.com> Sun Aug 23 22:27:24 2020 +0200
tree 4a828d9908c60362e4926e00189ee8112439d7f2
parent 12fc10f4da4b2a51bd4a69bb8c3572bd9095ed3f

MINIFICPP-1335 TailFile no longer generates an empty flowfile...

...in every onTrigger call when used without delimiter

Signed-off-by: Marton Szasz <szaszm01@gmail.com>

This closes #876

extensions/standard-processors/processors/TailFile.cpp

diff --git a/extensions/standard-processors/processors/TailFile.cpp b/extensions/standard-processors/processors/TailFile.cpp
index c5d2a1a..913fb59 100644
--- a/extensions/standard-processors/processors/TailFile.cpp
+++ b/extensions/standard-processors/processors/TailFile.cpp
@@ -654,8 +654,12 @@
 void TailFile::processFile(const std::shared_ptr<core::ProcessSession> &session,
                            const std::string &full_file_name,
                            TailState &state) {
-  if (utils::file::FileUtils::file_size(full_file_name) < state.position_) {
+  uint64_t fsize = utils::file::FileUtils::file_size(full_file_name);
+  if (fsize < state.position_) {
     processRotatedFiles(session, state);
+  } else if (fsize == state.position_) {
+    logger_->log_trace("Skipping file %s as its size hasn't change since last read", state.file_name_);
+    return;
   }
 
   processSingleFile(session, full_file_name, state);