Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NIFI-4322: If there is a failure checkpointing FlowFile Repository, ensure that we continue trying 

Signed-off-by: Pierre Villard <pierre.villard.fr@gmail.com>

This closes #2146.
This commit is contained in:
Mark Payne 2017-09-12 08:59:16 -04:00 committed by Pierre Villard
parent b452f8c251
commit 0e50279467
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/WriteAheadFlowFileRepository.java
View File

@ -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);
}
}
};