diff --git a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java index 5e3f522a80178..52cac4bc84b0f 100644 --- a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java +++ b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java @@ -48,12 +48,12 @@ import java.util.Queue; import java.util.Random; import java.util.Set; +import java.util.TreeMap; import java.util.UUID; import java.util.concurrent.CompletableFuture; import java.util.concurrent.CompletionException; import java.util.concurrent.ConcurrentLinkedDeque; import java.util.concurrent.ConcurrentLinkedQueue; -import java.util.concurrent.ConcurrentNavigableMap; import java.util.concurrent.ConcurrentSkipListMap; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutionException; @@ -3203,7 +3203,7 @@ public PositionImpl getPreviousPosition(PositionImpl position) { return PositionImpl.get(position.getLedgerId(), position.getEntryId() - 1); } - final ConcurrentNavigableMap ledgersCopied = new ConcurrentSkipListMap<>(ledgers); + final NavigableMap ledgersCopied = new TreeMap<>(ledgers); // The previous position will be the last position of an earlier ledgers NavigableMap headMap = ledgersCopied.headMap(position.getLedgerId(), false);