From dd10a629e0bd28afbf8b909fcc375e160eeee14e Mon Sep 17 00:00:00 2001 From: gavingaozhangmin Date: Tue, 10 Aug 2021 19:27:02 +0800 Subject: [PATCH] change ledgersCopied to non concurrent map --- .../org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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);