We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 53deabc commit 5a51f02Copy full SHA for 5a51f02
1 file changed
core/file_server/event/BlockEventManager.cpp
@@ -131,7 +131,7 @@ void BlockedEventManager::GetFeedbackEvent(vector<Event*>& res) {
131
for (auto& key : keys) {
132
for (auto iter = mEventMap.begin(); iter != mEventMap.end();) {
133
auto& e = iter->second;
134
- if (e.mEvent != nullptr && e.mQueueKey == key) {
+ if (e.mEvent != nullptr && e.mQueueKey == key && !e.mEvent->IsReaderFlushTimeout()) {
135
res.push_back(e.mEvent);
136
iter = mEventMap.erase(iter);
137
} else {
0 commit comments