Skip to content

Commit 76a4feb

Browse files
authored
[ISSUE #142] fix replica cannot be synced (#143)
Signed-off-by: zhangyang21 <zhangyang21@xiaomi.com>
1 parent eb1b2e2 commit 76a4feb

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

src/main/java/io/openmessaging/storage/dledger/DLedgerEntryPusher.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -970,6 +970,7 @@ private void handleDoBatchAppend(long writeIndex, PushEntryRequest request,
970970
updateCommittedIndex(request.getTerm(), request.getCommitIndex());
971971
} catch (Throwable t) {
972972
logger.error("[HandleDoBatchAppend]", t);
973+
future.complete(buildResponse(request, DLedgerResponseCode.INCONSISTENT_STATE.getCode()));
973974
}
974975

975976
}

0 commit comments

Comments
 (0)