Github user gresockj commented on a diff in the pull request:
https://github.com/apache/nifi/pull/2133#discussion_r137839524
--- Diff:
nifi-commons/nifi-write-ahead-log/src/main/java/org/wali/MinimalLockingWriteAheadLog.java
---
@@ -474,8 +474,15 @@ private void recoverFromEdits(final Map<Object, T>
modifiableRecordMap, final Lo
subsequentTransactionId =
nextPartition.getNextRecoverableTransactionId();
} catch (final IOException e) {
logger.error("{} unexpectedly found End-of-File when
reading from {} for Transaction ID {}; "
- + "assuming crash and ignoring this transaction",
+ + "attempting to get the next recoverable
transaction ID",
--- End diff --
I had a thought that this would be necessary, but I'm not sure what the
ending condition would be. How would you determine that we've run out of
recovery files?
---
