diff --git a/pom.xml b/pom.xml index 72d0070..14bbaa9 100644 --- a/pom.xml +++ b/pom.xml @@ -6,7 +6,7 @@ org.menina raft - 1.2.6 + 1.2.7 UTF-8 diff --git a/src/main/java/org/menina/raft/storage/CombinationStorage.java b/src/main/java/org/menina/raft/storage/CombinationStorage.java index 41b550d..be98302 100644 --- a/src/main/java/org/menina/raft/storage/CombinationStorage.java +++ b/src/main/java/org/menina/raft/storage/CombinationStorage.java @@ -91,7 +91,7 @@ public List entries(long begin, long end) { readLock.lock(); try { long lowWatermark = buffer.lowWatermark(); - long highWatermark = Math.min(buffer.highWatermark(), end); + long highWatermark = Math.min(buffer.highWatermark(), end - 1); if (begin >= lowWatermark) { return buffer.entries(begin, highWatermark); } else if (begin < lowWatermark && end >= lowWatermark) {