We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 03d9ca0 commit fcabd3bCopy full SHA for fcabd3b
dledger/src/main/java/io/openmessaging/storage/dledger/DLedgerEntryPusher.java
@@ -793,6 +793,7 @@ private void sendBatchAppendEntryRequest() throws Exception {
793
responseFuture.whenComplete((x, ex) -> {
794
try {
795
pendingTotalSize.addAndGet(-1 * entriesSize);
796
+ wakeup();
797
PreConditions.check(ex == null, DLedgerResponseCode.UNKNOWN);
798
DLedgerResponseCode responseCode = DLedgerResponseCode.valueOf(x.getCode());
799
switch (responseCode) {
0 commit comments