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 b42dda8 commit 44ebb34Copy full SHA for 44ebb34
src/main/java/io/openmessaging/storage/dledger/DLedgerEntryPusher.java
@@ -244,7 +244,7 @@ private void checkResponseFuturesElapsed(final long endIndex) {
244
final long currTerm = this.memberState.currTerm();
245
final Map<Long, TimeoutFuture<AppendEntryResponse>> responses = this.pendingAppendResponsesByTerm.get(currTerm);
246
for (Map.Entry<Long, TimeoutFuture<AppendEntryResponse>> futureEntry : responses.entrySet()) {
247
- if (futureEntry.getKey() < endIndex) {
+ if (futureEntry.getKey() <= endIndex) {
248
AppendEntryResponse response = new AppendEntryResponse();
249
response.setGroup(memberState.getGroup());
250
response.setTerm(currTerm);
0 commit comments