This is an automated email from the ASF dual-hosted git repository. rgao pushed a commit to branch branch-2.9 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 5047498c04a2ef72a2b51188ab3eb39fbc3249df Author: lin chen <[email protected]> AuthorDate: Mon Feb 28 18:10:21 2022 +0800 fix npe in ManagedLedgerImpl (#14481) (cherry picked from commit 3da048c8a6df7404df4e6c3301370feb96c6c14b) --- .../java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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 8728753..c07b3ce 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 @@ -3183,9 +3183,11 @@ public class ManagedLedgerImpl implements ManagedLedger, CreateCallback { totalEntriesInCurrentLedger = 0; } } else { - totalEntriesInCurrentLedger = ledgers.get(currentLedgerId).getEntries(); + LedgerInfo ledgerInfo = ledgers.get(currentLedgerId); + totalEntriesInCurrentLedger = ledgerInfo != null ? ledgerInfo.getEntries() : 0; } + long unreadEntriesInCurrentLedger = totalEntriesInCurrentLedger - currentEntryId; if (unreadEntriesInCurrentLedger >= entriesToSkip) {
