You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by bb...@apache.org on 2016/12/05 21:08:20 UTC
nifi git commit: NIFI-3152: Ensure that we always close the
IndexWriter when appropriate in SimpleIndexManager,
even if an IOException is thrown when trying to commit the IndexWriter
Repository: nifi
Updated Branches:
refs/heads/master 7633fe35c -> fc0d336f3
NIFI-3152: Ensure that we always close the IndexWriter when appropriate in SimpleIndexManager, even if an IOException is thrown when trying to commit the IndexWriter
This closes #1300.
Signed-off-by: Bryan Bende <bb...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/fc0d336f
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/fc0d336f
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/fc0d336f
Branch: refs/heads/master
Commit: fc0d336f36a7ea8d6ba960eead48f4e7e41c070d
Parents: 7633fe3
Author: Mark Payne <ma...@hotmail.com>
Authored: Mon Dec 5 14:30:57 2016 -0500
Committer: Bryan Bende <bb...@apache.org>
Committed: Mon Dec 5 16:07:54 2016 -0500
----------------------------------------------------------------------
.../org/apache/nifi/provenance/lucene/SimpleIndexManager.java | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/nifi/blob/fc0d336f/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/lucene/SimpleIndexManager.java
----------------------------------------------------------------------
diff --git a/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/lucene/SimpleIndexManager.java b/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/lucene/SimpleIndexManager.java
index 9e3bacd..81816d2 100644
--- a/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/lucene/SimpleIndexManager.java
+++ b/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/lucene/SimpleIndexManager.java
@@ -158,8 +158,11 @@ public class SimpleIndexManager implements IndexManager {
} else if (count.getCount() <= 1) {
// we are finished with this writer.
logger.debug("Decrementing count for Index Writer for {} to {}; Closing writer", indexingDirectory, count.getCount() - 1);
- writer.commit();
- count.close();
+ try {
+ writer.commit();
+ } finally {
+ count.close();
+ }
} else {
// decrement the count.
logger.debug("Decrementing count for Index Writer for {} to {}", indexingDirectory, count.getCount() - 1);