diff --git a/fdbserver/DataDistributionQueue.actor.cpp b/fdbserver/DataDistributionQueue.actor.cpp index d0d12f0387..60c88b00d4 100644 --- a/fdbserver/DataDistributionQueue.actor.cpp +++ b/fdbserver/DataDistributionQueue.actor.cpp @@ -1378,6 +1378,7 @@ ACTOR Future 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)); } }