diff --git a/src/backend/distributed/commands/table.c b/src/backend/distributed/commands/table.c index e5a8101ea..34b328a92 100644 --- a/src/backend/distributed/commands/table.c +++ b/src/backend/distributed/commands/table.c @@ -360,6 +360,13 @@ PostprocessCreateTableStmtPartitionOf(CreateStmt *createStatement, const */ if (IsCitusTable(parentRelationId)) { + if(IsCitusTableType(parentRelationId, CITUS_LOCAL_TABLE)) + { + /* if it's a citus local table, we don't need distribution column */ + CreateCitusLocalTable(relationId, false); + return; + } + Var *parentDistributionColumn = DistPartitionKeyOrError(parentRelationId); char parentDistributionMethod = DISTRIBUTE_BY_HASH; char *parentRelationName = generate_qualified_relation_name(parentRelationId);