not advancing popped version of change feed sideband from another server

This commit is contained in:
Josh Slocum 2022-02-22 11:22:35 -06:00
parent f9f676abf9
commit e75ab5f3a0
1 changed files with 0 additions and 7 deletions

View File

@ -4686,13 +4686,6 @@ ACTOR Future<std::vector<Key>> fetchChangeFeedMetadata(StorageServer* data, KeyR
// We may just want to refactor this so updateStorage does explicit deletes based on
// changeFeedCleanupDurable and not use the mutation log at all for the change feed metadata cleanup.
// Then we wouldn't have to reset anything here
writeToMutationLog = true;
} else if (changeFeedInfo->emptyVersion < cfEntry.emptyVersion) {
TEST(true); // Got updated CF emptyVersion from a parallel fetchChangeFeedMetadata
changeFeedInfo->emptyVersion = cfEntry.emptyVersion;
writeToMutationLog = true;
}
if (writeToMutationLog) {
auto& mLV = data->addVersionToMutationLog(data->data().getLatestVersion());
data->addMutationToMutationLog(
mLV,