From 73c58b6160c66b5c45d1faf22c721d7df5ca3e9d Mon Sep 17 00:00:00 2001 From: Sait Talha Nisanci Date: Thu, 6 May 2021 14:23:47 +0300 Subject: [PATCH] Not consider old placements when disabling or removing a node --- src/backend/distributed/metadata/node_metadata.c | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/backend/distributed/metadata/node_metadata.c b/src/backend/distributed/metadata/node_metadata.c index 105f93088..c10aaedac 100644 --- a/src/backend/distributed/metadata/node_metadata.c +++ b/src/backend/distributed/metadata/node_metadata.c @@ -422,7 +422,7 @@ citus_disable_node(PG_FUNCTION_ARGS) char *nodeName = text_to_cstring(nodeNameText); WorkerNode *workerNode = ModifiableWorkerNode(nodeName, nodePort); bool isActive = false; - bool onlyConsiderActivePlacements = false; + bool onlyConsiderActivePlacements = true; MemoryContext savedContext = CurrentMemoryContext; PG_TRY(); @@ -1291,7 +1291,7 @@ RemoveNodeFromCluster(char *nodeName, int32 nodePort) */ DeleteAllReferenceTablePlacementsFromNodeGroup(workerNode->groupId); } - bool onlyConsiderActivePlacements = false; + bool onlyConsiderActivePlacements = true; if (NodeGroupHasShardPlacements(workerNode->groupId, onlyConsiderActivePlacements)) {