commit 43a9b6fe9f5bca055acfefe144cd78dd29c614ba
author lin chen <1572139390@qq.com> Mon Feb 28 18:10:21 2022 +0800
committer penghui <penghui@apache.org> Tue Mar 01 11:02:39 2022 +0800
tree aa465575edd817b49449ae77e95df82b13fe620f
parent 0bbf05b82e7ab8d2dce28f5ef2116a335ee81e84

fix npe in ManagedLedgerImpl (#14481)

(cherry picked from commit 3da048c8a6df7404df4e6c3301370feb96c6c14b)

managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java

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 @@
                     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) {