fix destination limiting and cancelling logic in move_to_removed_server case

This commit is contained in:
Josh Slocum 2022-03-31 09:22:56 -05:00
parent 4b4082fe62
commit 9e06881673
1 changed files with 1 additions and 0 deletions

View File

@ -1378,6 +1378,7 @@ ACTOR Future<Void> dataDistributionRelocator(DDQueueData* self, RelocateData rd,
} else {
TEST(true); // move to removed server
healthyDestinations.addDataInFlightToTeam(-metrics.bytes);
rd.completeDests.clear();
wait(delay(SERVER_KNOBS->RETRY_RELOCATESHARD_DELAY, TaskPriority::DataDistributionLaunch));
}
}