fix: missing mutations committed at newOldestVersion

This commit is contained in:
Evan Tschannen 2021-09-07 16:20:49 -07:00
parent f53ddf6720
commit 590da022ee
1 changed files with 1 additions and 1 deletions

View File

@ -4609,7 +4609,7 @@ ACTOR Future<Void> updateStorage(StorageServer* data) {
}
std::set<Key> modifiedChangeFeeds;
while (!data->changeFeedVersions.empty() && data->changeFeedVersions.front().second < newOldestVersion) {
while (!data->changeFeedVersions.empty() && data->changeFeedVersions.front().second <= newOldestVersion) {
modifiedChangeFeeds.insert(data->changeFeedVersions.front().first.begin(),
data->changeFeedVersions.front().first.end());
data->changeFeedVersions.pop_front();