diff --git a/src/backend/distributed/operations/stage_protocol.c b/src/backend/distributed/operations/stage_protocol.c index 71c178d16..891d3fb7e 100644 --- a/src/backend/distributed/operations/stage_protocol.c +++ b/src/backend/distributed/operations/stage_protocol.c @@ -411,6 +411,14 @@ CreateAppendDistributedShardPlacements(Oid relationId, int64 shardId, { int workerNodeIndex = attemptNumber % workerNodeCount; WorkerNode *workerNode = (WorkerNode *) list_nth(workerNodeList, workerNodeIndex); + + if (NodeIsCoordinator(workerNode)) + { + ereport(NOTICE, (errmsg( + "Creating placements for the append partitioned tables on the coordinator is not allowed."))); + continue; + } + uint32 nodeGroupId = workerNode->groupId; char *nodeName = workerNode->workerName; uint32 nodePort = workerNode->workerPort;