Skip to content

Commit

Permalink
[HUDI-2856] Bit cask disk map delete modified (apache#4116)
Browse files Browse the repository at this point in the history
* modified BitCaskDiskMap_close_function

* change iterators location to finally

* Update BitCaskDiskMap.java
  • Loading branch information
xuzifu666 committed Nov 26, 2021
1 parent 9028e6e commit 257a6a7
Showing 1 changed file with 3 additions and 3 deletions.
Expand Up @@ -281,12 +281,12 @@ public void close() {
}
}
}
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();
}
}
Expand Down

0 comments on commit 257a6a7

Please sign in to comment.