Found another change feed fetch and remove race

This commit is contained in:
Josh Slocum 2022-03-20 14:10:52 -05:00
parent f7f2c9e979
commit bed6d428fb
1 changed files with 3 additions and 2 deletions

View File

@ -4817,13 +4817,14 @@ ACTOR Future<Version> fetchChangeFeedApplier(StorageServer* data,
ASSERT(startVersion >= 0);
if (startVersion >= endVersion) {
if (startVersion >= endVersion || (changeFeedInfo->removing)) {
TEST(true); // Change Feed popped before fetch
TraceEvent(SevDebug, "FetchChangeFeedNoOp", data->thisServerID)
.detail("RangeID", rangeId.printable())
.detail("Range", range.toString())
.detail("StartVersion", startVersion)
.detail("EndVersion", endVersion);
.detail("EndVersion", endVersion)
.detail("Removing", changeFeedInfo->removing);
return invalidVersion;
}