diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/FSHLog.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/FSHLog.java index 5f9e3cd..0b1f33b 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/FSHLog.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/FSHLog.java @@ -1003,6 +1003,9 @@ public class FSHLog implements WAL { LOG.debug("Moved " + files.length + " WAL file(s) to " + FSUtils.getPath(this.fullPathArchiveDir)); } + if (!fs.delete(this.fullPathLogDir, false)) { + LOG.warn("Unable to delete " + this.fullPathLogDir); + } LOG.info("Closed WAL: " + toString()); }