[pulsar] branch branch-2.11 updated: [fix][broker]fix multi invocation for ledger createComplete (#18975)

[technoboy]

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

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


The following commit(s) were added to refs/heads/branch-2.11 by this push:
     new 88199c11b51 [fix][broker]fix multi invocation for ledger 
createComplete (#18975)
88199c11b51 is described below

commit 88199c11b5120ef0c8024d5cc852f38eb48e4f4c
Author: AloysZhang <lofterzh...@gmail.com>
AuthorDate: Mon Dec 19 23:41:29 2022 +0800

    [fix][broker]fix multi invocation for ledger createComplete (#18975)
    
    ### Motivation
    
    fix multi invocation for ledger `createComplete`
    
    
    ### Modifications
    
    Only call `createComplete` at the point of creating ledger timeout if the 
ledger is not created normally
---
 .../main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java | 2 +-
 1 file changed, 1 insertion(+), 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
index 1fbdee5fa21..912908433cd 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
@@ -3820,12 +3820,12 @@ public class ManagedLedgerImpl implements 
ManagedLedger, CreateCallback {
                 if (log.isDebugEnabled()) {
                     log.debug("[{}] Timeout creating ledger", name);
                 }
+                cb.createComplete(BKException.Code.TimeoutException, null, 
ledgerCreated);
             } else {
                 if (log.isDebugEnabled()) {
                     log.debug("[{}] Ledger already created when timeout task 
is triggered", name);
                 }
             }
-            cb.createComplete(BKException.Code.TimeoutException, null, 
ledgerCreated);
         }, config.getMetadataOperationsTimeoutSeconds(), TimeUnit.SECONDS);
     }