From bbccd3f9b847237e996cb1da0065b34958ef7365 Mon Sep 17 00:00:00 2001 From: fanjianye Date: Tue, 23 Jul 2024 12:02:18 +0800 Subject: [PATCH] fix dead lock in handleBookieFailure --- .../main/java/org/apache/bookkeeper/proto/BookieClientImpl.java | 2 +- 1 file changed, 1 insertion(+), 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 index a12d9fd64d5..0c9225649b4 100644 --- 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