Matt Gilman created NIFI-3977:
---------------------------------
Summary: Empty queue issue when swap file is incomplete/corrupt
Key: NIFI-3977
URL: https://issues.apache.org/jira/browse/NIFI-3977
Project: Apache NiFi
Issue Type: Bug
Components: Core Framework
Reporter: Matt Gilman
Priority: Minor
When dropping the contents of a queue, if some of the data is swapped out and
the swap file cannot be completely read we want to attempt to drop what is
readable. However, because of IncompleteSwapFileException exception that is
being thrown the drop method is never called [1]. Subsequently, that swap file
is removed from the current drop locations without actually dropping the flow
files [2]. The swap location should be restored the next time the swap files
are recovered.
[1]
https://github.com/apache/nifi/blob/rel/nifi-1.2.0/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardFlowFileQueue.java#L1154
[2]
https://github.com/apache/nifi/blob/rel/nifi-1.2.0/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/StandardFlowFileQueue.java#L1186
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
