This reverts commit 257a6a7456.
This commit is contained in:
@@ -281,12 +281,12 @@ public final class BitCaskDiskMap<T extends Serializable, R extends Serializable
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
writeOnlyFile.delete();
|
||||||
|
this.iterators.forEach(ClosableIterator::close);
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
// delete the file for any sort of exception
|
// delete the file for any sort of exception
|
||||||
LOG.error("BitCaskDisMap close error ", e);
|
|
||||||
} finally {
|
|
||||||
this.iterators.forEach(ClosableIterator::close);
|
|
||||||
writeOnlyFile.delete();
|
writeOnlyFile.delete();
|
||||||
|
} finally {
|
||||||
super.close();
|
super.close();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user