Apache/nifi
1
0
Fork 0
mirror of https://github.com/apache/nifi.git synced 2025-02-28 06:29:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

NIFI-302: Blacklist a partition if IOException is thrown on rollover

Browse Source
This commit is contained in:
Mark Payne 2015-03-06 15:17:56 -05:00
parent f9620cc368
commit 608f8007ed
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
nifi/nifi-commons/nifi-write-ahead-log/src/main/java/org/wali/MinimalLockingWriteAheadLog.java
View File

@ -500,7 +500,12 @@ public final class MinimalLockingWriteAheadLog<T> implements WriteAheadRepositor
swapLocations = new HashSet<>(externalLocations); swapLocations = new HashSet<>(externalLocations);
for (final Partition<T> partition : partitions) { for (final Partition<T> partition : partitions) {
partition.rollover(); try {
partition.rollover();
} catch (final IOException ioe) {
partition.blackList();
throw ioe;
}
} }
// notify global sync with the write lock held. We do this because we don't want the repository to get updated // notify global sync with the write lock held. We do this because we don't want the repository to get updated