Skip to content

Commit 888883a

Browse files
cserwendengzhiwen1
andauthored
[ISSUE #251] Fix: checkAbnormalFuture of slave will not work if the network is abnormal
Co-authored-by: dengzhiwen1 <dengzhiwen1@xiaomi.com>
1 parent c491296 commit 888883a

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1010,7 +1010,7 @@ private void checkAppendFuture(long endIndex) {
10101010
if (minFastForwardIndex == Long.MAX_VALUE) {
10111011
return;
10121012
}
1013-
Pair<PushEntryRequest, CompletableFuture<PushEntryResponse>> pair = writeRequestMap.get(minFastForwardIndex);
1013+
Pair<PushEntryRequest, CompletableFuture<PushEntryResponse>> pair = writeRequestMap.remove(minFastForwardIndex);
10141014
if (pair == null) {
10151015
return;
10161016
}

0 commit comments

Comments
 (0)