Skip to content

Commit 4030737

Browse files
committed
fix
1 parent 606db74 commit 4030737

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

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

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -411,7 +411,9 @@ 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);
416+
});
415417
} else {
416418
pcbc.addEntry(ledgerId, masterKey, entryId,
417419
toSend, cb, ctx, options, allowFastFail, writeFlags);

0 commit comments

Comments
 (0)