unload bundle causes topic fence, OpAddEntry NPE appears in addComple…

…te. apache#17737
lightzhao · Sep 23, 2022 · a5722e3 · a5722e3
1 parent 3bc673c
commit a5722e3
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpAddEntry.java b/managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/OpAddEntry.java
@@ -165,6 +165,10 @@ public void addComplete(int rc, final LedgerHandle lh, long entryId, Object ctx)
             return;
         }
 
+        if(ledger == null){
+            return;
+        }
+
         if (ledger.getId() != lh.getId()) {
             log.warn("[{}] ledgerId {} doesn't match with acked ledgerId {}", ml.getName(), ledger.getId(), lh.getId());
         }