external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Not consider old placements when disabling or removing a node

pull/4960/head
Sait Talha Nisanci 2021-05-06 14:23:47 +03:00
parent a20cc3b36a
commit 73c58b6160
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/backend/distributed/metadata/node_metadata.c
View File

@ -422,7 +422,7 @@ citus_disable_node(PG_FUNCTION_ARGS)
char *nodeName = text_to_cstring(nodeNameText); char *nodeName = text_to_cstring(nodeNameText);
WorkerNode *workerNode = ModifiableWorkerNode(nodeName, nodePort); WorkerNode *workerNode = ModifiableWorkerNode(nodeName, nodePort);
bool isActive = false; bool isActive = false;
bool onlyConsiderActivePlacements = false; bool onlyConsiderActivePlacements = true;
MemoryContext savedContext = CurrentMemoryContext; MemoryContext savedContext = CurrentMemoryContext;
PG_TRY(); PG_TRY();
@ -1291,7 +1291,7 @@ RemoveNodeFromCluster(char *nodeName, int32 nodePort)
*/ */
DeleteAllReferenceTablePlacementsFromNodeGroup(workerNode->groupId); DeleteAllReferenceTablePlacementsFromNodeGroup(workerNode->groupId);
} }
bool onlyConsiderActivePlacements = false; bool onlyConsiderActivePlacements = true;
if (NodeGroupHasShardPlacements(workerNode->groupId, if (NodeGroupHasShardPlacements(workerNode->groupId,
onlyConsiderActivePlacements)) onlyConsiderActivePlacements))
{ {