.../org/apache/hadoop/hbase/io/hfile/bucket/FileIOEngine.java | 10 ++++++++++ .../apache/hadoop/hbase/io/hfile/bucket/TestFileIOEngine.java | 0 2 files changed, 10 insertions(+) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/bucket/FileIOEngine.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/bucket/FileIOEngine.java index 7586d57..4fbdf67 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/bucket/FileIOEngine.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/io/hfile/bucket/FileIOEngine.java @@ -57,6 +57,16 @@ public class FileIOEngine implements IOEngine { this.capacity = this.sizePerFile * filePaths.length; this.filePaths = filePaths; this.fileChannels = new FileChannel[filePaths.length]; + for (String filePath : filePaths) { + File file = new File(filePath); + if (file.exists()) { + if (LOG.isDebugEnabled()) { + LOG.debug("File " + filePath + " already exists. Deleting!!"); + } + file.delete(); + // If deletion fails still we can manage with the writes + } + } this.rafs = new RandomAccessFile[filePaths.length]; for (int i = 0; i < filePaths.length; i++) { String filePath = filePaths[i];