You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by da...@apache.org on 2021/12/04 09:40:29 UTC
[hudi] 05/26: Revert "[HUDI-2856] Bit cask disk map delete modified (#4116)" (#4171)
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 <et...@gmail.com>
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();
}
}