diff --git a/src/backend/distributed/commands/create_distributed_table.c b/src/backend/distributed/commands/create_distributed_table.c index 26a905f23..62bcbb14b 100644 --- a/src/backend/distributed/commands/create_distributed_table.c +++ b/src/backend/distributed/commands/create_distributed_table.c @@ -959,7 +959,9 @@ ColocationIdForNewTable(Oid relationId, Var *distributionColumn, } else if (IsColocateWithNone(colocateWithTableName)) { - colocationId = GetNextColocationId(); + colocationId = CreateColocationGroup(shardCount, ShardReplicationFactor, + distributionColumnType, + distributionColumnCollation); createdColocationGroup = true; }