This is an automated email from the ASF dual-hosted git repository. danny0405 pushed a commit to branch release-0.10.0 in repository https://gitbox.apache.org/repos/asf/hudi.git
commit 7df81a6b6ff5405e9da93289789ec84a280cf8d7 Author: Y Ethan Guo <[email protected]> AuthorDate: Tue Nov 30 22:08:44 2021 -0800 Revert "[HUDI-2856] Bit cask disk map delete modified (#4116)" (#4171) This reverts commit 257a6a74569cdb500b06c53b92d05f6f5833aa31. (cherry picked from commit 9b254b6fc5779b6105b2fa9aeff5ad5b79407f84) --- .../java/org/apache/hudi/common/util/collection/BitCaskDiskMap.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/hudi-common/src/main/java/org/apache/hudi/common/util/collection/BitCaskDiskMap.java b/hudi-common/src/main/java/org/apache/hudi/common/util/collection/BitCaskDiskMap.java index 7644afa..289901d 100644 --- a/hudi-common/src/main/java/org/apache/hudi/common/util/collection/BitCaskDiskMap.java +++ b/hudi-common/src/main/java/org/apache/hudi/common/util/collection/BitCaskDiskMap.java @@ -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 - LOG.error("BitCaskDisMap close error ", e); - } finally { - this.iterators.forEach(ClosableIterator::close); writeOnlyFile.delete(); + } finally { super.close(); } }
