Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

fix getPreviousPosition npe #11621

Merged
merged 4 commits into from Aug 11, 2021
Merged

fix getPreviousPosition npe #11621

Changes from 2 commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
1854226
fix getPreviousPosition npe
Aug 10, 2021
d2722eb
make a copy of ledgers
Aug 10, 2021
dd10a62
change ledgersCopied to non concurrent map
Aug 10, 2021
ede0423
add null checker for copying ledgers too expensive
gaozhangmin Aug 10, 2021
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
4 changes: 3 additions & 1 deletion managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java
View file
Open in desktop
Expand Up @@ -53,6 +53,7 @@
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;
Expand Down Expand Up @@ -3202,8 +3203,9 @@ public PositionImpl getPreviousPosition(PositionImpl position) {
return PositionImpl.get(position.getLedgerId(), position.getEntryId() - 1);
}

final ConcurrentNavigableMap<Long, LedgerInfo> ledgersCopied = new ConcurrentSkipListMap<>(ledgers);
gaozhangmin marked this conversation as resolved.
Show resolved Hide resolved
// The previous position will be the last position of an earlier ledgers
NavigableMap<Long, LedgerInfo> headMap = ledgers.headMap(position.getLedgerId(), false);
NavigableMap<Long, LedgerInfo> headMap = ledgersCopied.headMap(position.getLedgerId(), false);
BewareMyPower marked this conversation as resolved.
Show resolved Hide resolved

if (headMap.isEmpty()) {
// There is no previous ledger, return an invalid position in the current ledger
Expand Down