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

Address feedback

pull/1092/head
Murat Tuncer 2017-01-06 12:01:04 +03:00
parent 205f6563fa
commit e35f4c836d
1 changed files with 15 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
src/backend/distributed/utils/node_metadata.c
View File

@ -121,19 +121,22 @@ master_remove_node(PG_FUNCTION_ARGS)
EnsureSuperUser(); EnsureSuperUser();
hasShardPlacements = NodeHasActiveShardPlacements(nodeNameString, nodePort); hasShardPlacements = NodeHasActiveShardPlacements(nodeNameString, nodePort);
if (hasShardPlacements && force) if (hasShardPlacements)
{ {
ereport(NOTICE, (errmsg("Node %s:%d has active shard placements. Some " if (force)
"queries may fail after this operation. Use " {
"select master_add_node('%s', %d) to add this " ereport(NOTICE, (errmsg("Node %s:%d has active shard placements. Some "
"node back.", "queries may fail after this operation. Use "
nodeNameString, nodePort, nodeNameString, "select master_add_node('%s', %d) to add this "
nodePort))); "node back.",
} nodeNameString, nodePort, nodeNameString,
else if (hasShardPlacements) nodePort)));
{ }
ereport(ERROR, (errmsg("you cannot remove a node which has active " else
"shard placements"))); {
ereport(ERROR, (errmsg("you cannot remove a node which has active "
"shard placements")));
}
} }
workerNode = FindWorkerNode(nodeNameString, nodePort); workerNode = FindWorkerNode(nodeNameString, nodePort);