diff --git a/fdbserver/LogSystemPeekCursor.actor.cpp b/fdbserver/LogSystemPeekCursor.actor.cpp index 99c0c221b7..bac736afec 100644 --- a/fdbserver/LogSystemPeekCursor.actor.cpp +++ b/fdbserver/LogSystemPeekCursor.actor.cpp @@ -152,6 +152,9 @@ ACTOR Future serverPeekParallelGetMore( ILogSystem::ServerPeekCursor* self while(self->futureResults.size() < SERVER_KNOBS->PARALLEL_GET_MORE_REQUESTS && self->interf->get().present()) { self->futureResults.push_back( brokenPromiseToNever( self->interf->get().interf().peekMessages.getReply(TLogPeekRequest(self->messageVersion.version,self->tag,self->returnIfBlocked, self->onlySpilled, std::make_pair(self->randomID, self->sequence++)), taskID) ) ); } + } else if (self->futureResults.size() == 1) { + self->randomID = deterministicRandom()->randomUniqueID(); + self->sequence = 0; } else if (self->futureResults.size() == 0) { return Void(); }