diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.java index a0411975be..f18a78c155 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/AbstractFSWAL.java @@ -631,7 +631,7 @@ public abstract class AbstractFSWAL implements WAL { private void cleanOldLogs() throws IOException { List> logsToArchive = null; long now = System.nanoTime(); - boolean mayLogTooOld = nextLogTooOldNs > now; + boolean mayLogTooOld = nextLogTooOldNs <= now; ArrayList regionsBlockingWal = null; // For each log file, look at its Map of regions to highest sequence id; if all sequence ids // are older than what is currently in memory, the WAL can be GC'd.