From 5eedcafcfbf0ff1d5cca362c95459d0b1bbc97cb Mon Sep 17 00:00:00 2001 From: "A.J. Beamon" <aj.beamon@snowflake.com> Date: Fri, 29 Apr 2022 12:40:41 -0700 Subject: [PATCH] Mark a team as unhealthy when it is removed --- fdbserver/DDTeamCollection.actor.cpp | 1 + fdbserver/DataDistribution.actor.h | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/fdbserver/DDTeamCollection.actor.cpp b/fdbserver/DDTeamCollection.actor.cpp index 72cf7710d4..8c98ebef50 100644 --- a/fdbserver/DDTeamCollection.actor.cpp +++ b/fdbserver/DDTeamCollection.actor.cpp @@ -4762,6 +4762,7 @@ bool DDTeamCollection::removeTeam(Reference<TCTeamInfo> team) { ASSERT_WE_THINK(foundInMachineTeam); team->tracker.cancel(); + team->setHealthy(false); if (g_network->isSimulated()) { // Update server team information for consistency check in simulation traceTeamCollectionInfo(); diff --git a/fdbserver/DataDistribution.actor.h b/fdbserver/DataDistribution.actor.h index fe2daf8c00..719a7b6a49 100644 --- a/fdbserver/DataDistribution.actor.h +++ b/fdbserver/DataDistribution.actor.h @@ -65,7 +65,7 @@ struct IDataDistributionTeam { std::string getDesc() const { const auto& servers = getLastKnownServerInterfaces(); - std::string s = format("TeamID:%s", getTeamID().c_str()); + std::string s = format("TeamID %s; ", getTeamID().c_str()); s += format("Size %d; ", servers.size()); for (int i = 0; i < servers.size(); i++) { if (i)