fix dead lock in handleBookieFailure

apache · Jul 23, 2024 · bbccd3f · bbccd3f
1 parent 4ca020a
commit bbccd3f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookieClientImpl.java b/bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookieClientImpl.java
@@ -284,7 +284,7 @@ private void completeAdd(final int rc,
                              final BookieId addr,
                              final WriteCallback cb,
                              final Object ctx) {
-        cb.writeComplete(rc, ledgerId, entryId, addr, ctx);
+        executor.executeOrdered(ledgerId, () -> cb.writeComplete(rc, ledgerId, entryId, addr, ctx));
     }
 
     @Override