fix dead lock in handleBookieFailure

TakaHiR07 · Jul 22, 2024 · 3639c50 · 3639c50
1 parent 4ca020a
commit 3639c50
Showing 1 changed file with 2 additions 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
@@ -411,7 +411,8 @@ public void operationComplete(final int rc,
                                       PerChannelBookieClient pcbc) {
             try {
                 if (rc != BKException.Code.OK) {
-                    bookieClient.completeAdd(rc, ledgerId, entryId, addr, cb, ctx);
+                    bookieClient.executor.executeOrdered(ledgerId, () ->
+                            bookieClient.completeAdd(rc, ledgerId, entryId, addr, cb, ctx));
                 } else {
                     pcbc.addEntry(ledgerId, masterKey, entryId,
                             toSend, cb, ctx, options, allowFastFail, writeFlags);