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

Merge aa6cefacca into 2148922cb2

pull/415/merge
Brian Cloutier 2016-05-26 15:26:05 +00:00
parent 2148922cb2 aa6cefacca
commit c0d51f3c4c
2 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/backend/distributed/master/master_node_protocol.c
View File

@ -370,7 +370,9 @@ master_get_local_first_candidate_nodes(PG_FUNCTION_ARGS)
if (candidateNode == NULL)
{
ereport(ERROR, (errmsg("could only find %u of %u required nodes",
currentNodeCount, desiredNodeCount)));
currentNodeCount, desiredNodeCount),
errhint("If you're running a development cluster, consider running"
" SET citus.shard_replication_factor = %u;", currentNodeCount)));
}
}
@ -460,7 +462,9 @@ master_get_round_robin_candidate_nodes(PG_FUNCTION_ARGS)
if (candidateNode == NULL)
{
ereport(ERROR, (errmsg("could only find %u of %u required nodes",
currentNodeCount, desiredNodeCount)));
currentNodeCount, desiredNodeCount),
errhint("If you're running a development cluster, consider running"
" SET citus.shard_replication_factor = %u;", currentNodeCount)));
}
candidateDatum = WorkerNodeGetDatum(candidateNode, functionContext->tuple_desc);

4
src/backend/distributed/master/master_stage_protocol.c
View File

@ -124,7 +124,9 @@ master_create_empty_shard(PG_FUNCTION_ARGS)
if (candidateNode == NULL)
{
ereport(ERROR, (errmsg("could only find %u of %u possible nodes",
candidateNodeCount, attemptableNodeCount)));
candidateNodeCount, attemptableNodeCount),
errhint("If this is a development cluster, consider running"
" SET citus.shard_replication_factor = %u;", candidateNodeCount)));
}
candidateNodeList = lappend(candidateNodeList, candidateNode);