diff --git a/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/SortedLedgerStorage.java b/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/SortedLedgerStorage.java index 60822b8fa01..bd414ee1146 100644 --- a/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/SortedLedgerStorage.java +++ b/bookkeeper-server/src/main/java/org/apache/bookkeeper/bookie/SortedLedgerStorage.java @@ -144,9 +144,7 @@ public boolean ledgerExists(long ledgerId) throws IOException { // the O(1) for the ledgerCache. if (!interleavedLedgerStorage.ledgerExists(ledgerId)) { EntryKeyValue kv = memTable.getLastEntry(ledgerId); - if (null == kv) { - return interleavedLedgerStorage.ledgerExists(ledgerId); - } + return null != kv; } return true; }