[pulsar] 01/14: [managedledger] NPE on OpAddEntry while ManagedLedger is closing (#12364)

[penghui]

This is an automated email from the ASF dual-hosted git repository.

penghui pushed a commit to branch branch-2.8
in repository https://gitbox.apache.org/repos/asf/pulsar.git

commit f06db554ae2dc8b3d2d6a2135a9e282d4544edf7
Author: Nicolò Boschi <boschi1...@gmail.com>
AuthorDate: Fri Oct 15 01:15:52 2021 +0200

    [managedledger] NPE on OpAddEntry while ManagedLedger is closing (#12364)
    
    (cherry picked from commit cc70a1f5e4ef228ca040433249d54c6e22711c20)
---
 .../main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java  | 1 +
 1 file changed, 1 insertion(+)

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 731c6d8..fc5abb9 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
@@ -1679,6 +1679,7 @@ public class ManagedLedgerImpl implements ManagedLedger, 
CreateCallback {
     void clearPendingAddEntries(ManagedLedgerException e) {
         while (!pendingAddEntries.isEmpty()) {
             OpAddEntry op = pendingAddEntries.poll();
+            op.close();
             op.failed(e);
         }
     }