We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent df70e32 commit 7df81a6Copy full SHA for 7df81a6
hudi-common/src/main/java/org/apache/hudi/common/util/collection/BitCaskDiskMap.java
@@ -281,12 +281,12 @@ public void close() {
281
}
282
283
284
+ writeOnlyFile.delete();
285
+ this.iterators.forEach(ClosableIterator::close);
286
} catch (Exception e) {
287
// delete the file for any sort of exception
- LOG.error("BitCaskDisMap close error ", e);
- } finally {
288
- this.iterators.forEach(ClosableIterator::close);
289
writeOnlyFile.delete();
+ } finally {
290
super.close();
291
292
0 commit comments