You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by eo...@apache.org on 2022/02/28 10:12:08 UTC
[pulsar] branch master updated: fix npe in ManagedLedgerImpl (#14481)
This is an automated email from the ASF dual-hosted git repository.
eolivelli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 3da048c fix npe in ManagedLedgerImpl (#14481)
3da048c is described below
commit 3da048c8a6df7404df4e6c3301370feb96c6c14b
Author: lin chen <15...@qq.com>
AuthorDate: Mon Feb 28 18:10:21 2022 +0800
fix npe in ManagedLedgerImpl (#14481)
---
.../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) {