fix npe in ManagedLedgerImpl (apache#14481)

(cherry picked from commit 3da048c)
drianpauL · Mar 1, 2022 · 43a9b6f · 43a9b6f
1 parent 0bbf05b
commit 43a9b6f
Showing 1 changed file with 3 additions and 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
@@ -3252,9 +3252,11 @@ public PositionImpl getPositionAfterN(final PositionImpl startPosition, long n,
                     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) {