[
https://issues.apache.org/jira/browse/NIFI-6416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Brandon DeVries updated NIFI-6416:
----------------------------------
Description:
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.
Specifically:
{code:java}
synchronized (this.swapLocationSuffixes) {
this.swapLocationSuffixes.add(normalizeSwapLocation(swapLocation));
}{code}
Should be:
{code:java}
synchronized (this.swapLocationSuffixes) {
this.swapLocationSuffixes.remove(normalizeSwapLocation(swapLocation));
}{code}
[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]
was:
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]
> 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
> Priority: Minor
>
> 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.
> Specifically:
> {code:java}
> synchronized (this.swapLocationSuffixes) {
> this.swapLocationSuffixes.add(normalizeSwapLocation(swapLocation));
> }{code}
> Should be:
> {code:java}
> synchronized (this.swapLocationSuffixes) {
> this.swapLocationSuffixes.remove(normalizeSwapLocation(swapLocation));
> }{code}
>
>
> [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.14#76016)
