You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2022/03/01 03:12:37 UTC
[pulsar] 10/10: fix npe in ManagedLedgerImpl (#14481)
This is an automated email from the ASF dual-hosted git repository.
penghui pushed a commit to branch branch-2.10
in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 43a9b6fe9f5bca055acfefe144cd78dd29c614ba
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 bfa3336..a13cf68 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
@@ -3252,9 +3252,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) {