From e6c375eb812488a3b264fc9b7bc367c4ac3bd778 Mon Sep 17 00:00:00 2001 From: Brian Cloutier Date: Wed, 12 Jul 2017 12:38:37 +0300 Subject: [PATCH] Tiny refactor to master_create_empty_shard --- src/backend/distributed/master/master_stage_protocol.c | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/src/backend/distributed/master/master_stage_protocol.c b/src/backend/distributed/master/master_stage_protocol.c index ac48ae740..0ea42e770 100644 --- a/src/backend/distributed/master/master_stage_protocol.c +++ b/src/backend/distributed/master/master_stage_protocol.c @@ -70,7 +70,6 @@ master_create_empty_shard(PG_FUNCTION_ARGS) { text *relationNameText = PG_GETARG_TEXT_P(0); char *relationName = text_to_cstring(relationNameText); - List *workerNodeList = NIL; uint64 shardId = INVALID_SHARD_ID; uint32 attemptableNodeCount = 0; uint32 liveNodeCount = 0; @@ -88,8 +87,6 @@ master_create_empty_shard(PG_FUNCTION_ARGS) CheckCitusVersion(ERROR); - workerNodeList = ActiveWorkerNodeList(); - EnsureTablePermissions(relationId, ACL_INSERT); CheckDistributedTable(relationId); @@ -155,6 +152,7 @@ master_create_empty_shard(PG_FUNCTION_ARGS) } else if (ShardPlacementPolicy == SHARD_PLACEMENT_ROUND_ROBIN) { + List *workerNodeList = ActiveWorkerNodeList(); candidateNode = WorkerGetRoundRobinCandidateNode(workerNodeList, shardId, candidateNodeIndex); }