[managedledger] NPE on OpAddEntry while ManagedLedger is closing (apa…

…che#12364)
lujp · Oct 14, 2021 · cc70a1f · cc70a1f
1 parent 21b758c
commit cc70a1f
Showing 1 changed file with 1 addition and 0 deletions.
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
@@ -1680,6 +1680,7 @@ public ManagedLedgerInterceptor getManagedLedgerInterceptor() {
     void clearPendingAddEntries(ManagedLedgerException e) {
         while (!pendingAddEntries.isEmpty()) {
             OpAddEntry op = pendingAddEntries.poll();
+            op.close();
             op.failed(e);
         }
     }