Skip to content

Commit 3639c50

Browse files
author
fanjianye
committed
fix dead lock in handleBookieFailure
1 parent 4ca020a commit 3639c50

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookieClientImpl.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -411,7 +411,8 @@ public void operationComplete(final int rc,
411411
PerChannelBookieClient pcbc) {
412412
try {
413413
if (rc != BKException.Code.OK) {
414-
bookieClient.completeAdd(rc, ledgerId, entryId, addr, cb, ctx);
414+
bookieClient.executor.executeOrdered(ledgerId, () ->
415+
bookieClient.completeAdd(rc, ledgerId, entryId, addr, cb, ctx));
415416
} else {
416417
pcbc.addEntry(ledgerId, masterKey, entryId,
417418
toSend, cb, ctx, options, allowFastFail, writeFlags);

0 commit comments

Comments
 (0)