DelayedFetchLogOperation will not be trigged to complete when replica number set to 1 #777
Description
Search before asking
- I searched in the issues and found nothing similar.
Fluss version
0.6.0 (latest release)
Please describe the bug 🐞
In #768, we directly remove the tryCompleteDelayedOperations in Replica#appendRecordsToLeader():
This may cause DelayedFetchLogOperation not be trigged to complete when replica number set to 1 because there are no follower to fetch log from leader and trigger complete DelayedFetchLogOperation. In this case, DelayedFetchLogOperation will only finished when the wait time timeout.
Solution
No response
Are you willing to submit a PR?
- I'm willing to submit a PR!