diff --git a/fdbserver/LogSystemPeekCursor.actor.cpp b/fdbserver/LogSystemPeekCursor.actor.cpp index 7cb1d1f9e8..8b7ab92812 100644 --- a/fdbserver/LogSystemPeekCursor.actor.cpp +++ b/fdbserver/LogSystemPeekCursor.actor.cpp @@ -977,6 +977,8 @@ ACTOR Future bufferedGetMore( ILogSystem::BufferedCursor* self, int taskID throw internal_error(); } + Void _ = wait(yield()); + state Version targetVersion = std::min(self->end, self->messageVersion.version + SERVER_KNOBS->VERSIONS_PER_BATCH); self->messages.clear();