Repository: incubator-nifi Updated Branches: refs/heads/NIFI-33 ece5ce140 -> 779718471
NIFI-33: On failure, was attempting to remove non-existent file; fixed this Project: http://git-wip-us.apache.org/repos/asf/incubator-nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-nifi/commit/77971847 Tree: http://git-wip-us.apache.org/repos/asf/incubator-nifi/tree/77971847 Diff: http://git-wip-us.apache.org/repos/asf/incubator-nifi/diff/77971847 Branch: refs/heads/NIFI-33 Commit: 77971847129133bef0d9340e44b23c8d352be303 Parents: ece5ce1 Author: Mark Payne <[email protected]> Authored: Mon Dec 15 15:02:44 2014 -0500 Committer: Mark Payne <[email protected]> Committed: Mon Dec 15 15:02:44 2014 -0500 ---------------------------------------------------------------------- .../java/org/apache/nifi/controller/FileSystemSwapManager.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/77971847/nar-bundles/framework-bundle/framework/core/src/main/java/org/apache/nifi/controller/FileSystemSwapManager.java ---------------------------------------------------------------------- diff --git a/nar-bundles/framework-bundle/framework/core/src/main/java/org/apache/nifi/controller/FileSystemSwapManager.java b/nar-bundles/framework-bundle/framework/core/src/main/java/org/apache/nifi/controller/FileSystemSwapManager.java index bf76bad..c1ebc97 100644 --- a/nar-bundles/framework-bundle/framework/core/src/main/java/org/apache/nifi/controller/FileSystemSwapManager.java +++ b/nar-bundles/framework-bundle/framework/core/src/main/java/org/apache/nifi/controller/FileSystemSwapManager.java @@ -549,7 +549,7 @@ public class FileSystemSwapManager implements FlowFileSwapManager { swapQueue.getQueue().add(swapFile); } else { - swapFile.delete(); + swapTempFile.delete(); } } }
