From 9e0688167393185f523c0786a3a318938d109d3a Mon Sep 17 00:00:00 2001 From: Josh Slocum Date: Thu, 31 Mar 2022 09:22:56 -0500 Subject: [PATCH] fix destination limiting and cancelling logic in move_to_removed_server case --- fdbserver/DataDistributionQueue.actor.cpp | 1 + 1 file changed, 1 insertion(+) 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)); } }