Brandon DeVries created NIFI-6416:
-------------------------------------

             Summary: WriteAheadFlowFileRepository.swapFlowFilesIn() not 
removing swapLocationSuffixes
                 Key: NIFI-6416
                 URL: https://issues.apache.org/jira/browse/NIFI-6416
             Project: Apache NiFi
          Issue Type: Bug
          Components: Core Framework
            Reporter: Brandon DeVries


WriteAheadFlowFileRepository maintains a list of swapLocationSuffixes.  This is 
added to when records are swapped out, and removed from when records are 
swapped in when the repo is updated[1].  However, the swapFlowFilesIn method[2] 
appears to be adding instead of removing the specified swap location.

 

[1] 
[https://github.com/apache/nifi/blob/f08c2ee43f39584b7d4e76d61d7d4aaa889068fd/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/WriteAheadFlowFileRepository.java#L372-L377]

[2]  
[https://github.com/apache/nifi/blob/f08c2ee43f39584b7d4e76d61d7d4aaa889068fd/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/WriteAheadFlowFileRepository.java#L518]



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to