This is an automated email from the ASF dual-hosted git repository.

pvillard pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git


The following commit(s) were added to refs/heads/main by this push:
     new 4aaec5a  NIFI-8020 Make sure TailFile doesn't leave FileChannel open 
when handling NUL characters
4aaec5a is described below

commit 4aaec5aa3878f1abd3c2b98ba7659431f0a8c9c3
Author: Tamas Palfy <[email protected]>
AuthorDate: Tue Nov 17 20:44:42 2020 +0100

    NIFI-8020 Make sure TailFile doesn't leave FileChannel open when handling 
NUL characters
    
    Signed-off-by: Pierre Villard <[email protected]>
    
    This closes #4671.
---
 .../src/main/java/org/apache/nifi/processors/standard/TailFile.java      | 1 +
 1 file changed, 1 insertion(+)

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 6343d32..8d96e44 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
@@ -799,6 +799,7 @@ public class TailFile extends AbstractProcessor {
 
         if (abort.get() != null) {
             session.remove(flowFile);
+            tfo.setState(new TailFileState(tailFile, file, reader, position, 
timestamp, length, checksum, state.getBuffer()));
             throw abort.get();
         }
 

Reply via email to