[HUDI-2856] Bit cask disk map delete modified (#4116)
* modified BitCaskDiskMap_close_function * change iterators location to finally * Update BitCaskDiskMap.java
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) {
|
||||
// delete the file for any sort of exception
|
||||
writeOnlyFile.delete();
|
||||
LOG.error("BitCaskDisMap close error ", e);
|
||||
} finally {
|
||||
this.iterators.forEach(ClosableIterator::close);
|
||||
writeOnlyFile.delete();
|
||||
super.close();
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user