[pulsar] 02/11: [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.7
in repository https://gitbox.apache.org/repos/asf/pulsar.git

commit ebacd1039c7f31ba0ddaa2eb495dfdf9758d61e0
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 3f69bcb..497222e 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
@@ -1514,6 +1514,7 @@ public class ManagedLedgerImpl implements ManagedLedger, 
CreateCallback {
     void clearPendingAddEntries(ManagedLedgerException e) {
         while (!pendingAddEntries.isEmpty()) {
             OpAddEntry op = pendingAddEntries.poll();
+            op.close();
             op.failed(e);
         }
     }