You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by pv...@apache.org on 2017/09/13 10:14:48 UTC
nifi git commit: NIFI-4322: If there is a failure checkpointing
FlowFile Repository, ensure that we continue trying
Repository: nifi
Updated Branches:
refs/heads/master b452f8c25 -> 0e5027946
NIFI-4322: If there is a failure checkpointing FlowFile Repository, ensure that we continue trying
Signed-off-by: Pierre Villard <pi...@gmail.com>
This closes #2146.
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/0e502794
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/0e502794
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/0e502794
Branch: refs/heads/master
Commit: 0e5027946756ca4696aeb9ecd769b2cddf1f16cb
Parents: b452f8c
Author: Mark Payne <ma...@hotmail.com>
Authored: Tue Sep 12 08:59:16 2017 -0400
Committer: Pierre Villard <pi...@gmail.com>
Committed: Wed Sep 13 12:14:13 2017 +0200
----------------------------------------------------------------------
.../nifi/controller/repository/WriteAheadFlowFileRepository.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/nifi/blob/0e502794/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/WriteAheadFlowFileRepository.java
----------------------------------------------------------------------
diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/WriteAheadFlowFileRepository.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/WriteAheadFlowFileRepository.java
index 9f8ff98..00dde06 100644
--- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/WriteAheadFlowFileRepository.java
+++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/WriteAheadFlowFileRepository.java
@@ -425,8 +425,8 @@ public class WriteAheadFlowFileRepository implements FlowFileRepository, SyncLis
final long millis = TimeUnit.MILLISECONDS.convert(end - start, TimeUnit.NANOSECONDS);
logger.info("Successfully checkpointed FlowFile Repository with {} records in {} milliseconds",
new Object[]{numRecordsCheckpointed, millis});
- } catch (final IOException e) {
- logger.error("Unable to checkpoint FlowFile Repository due to " + e.toString(), e);
+ } catch (final Throwable t) {
+ logger.error("Unable to checkpoint FlowFile Repository due to " + t.toString(), t);
}
}
};