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 <pierre.villard...@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 <marka...@hotmail.com> Authored: Tue Sep 12 08:59:16 2017 -0400 Committer: Pierre Villard <pierre.villard...@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); } } };
