You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by rg...@apache.org on 2022/03/01 16:24:29 UTC
[pulsar] 20/21: fix npe in ManagedLedgerImpl (#14481)
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 <15...@qq.com>
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) {