pull/7219/head
Onur Tirtir 2023-09-25 10:55:33 +03:00
parent f54f9166a5
commit a553e38250
1 changed files with 12 additions and 12 deletions

View File

@ -445,18 +445,18 @@ CreateDistributedTableConcurrently(Oid relationId, char *distributionColumnName,
if (!IsColocateWithDefault(colocateWithTableName) && !IsColocateWithNone( if (!IsColocateWithDefault(colocateWithTableName) && !IsColocateWithNone(
colocateWithTableName)) colocateWithTableName))
{ {
if (replicationModel != REPLICATION_MODEL_STREAMING) if (replicationModel != REPLICATION_MODEL_STREAMING)
{ {
ereport(ERROR, (errmsg("cannot create distributed table " ereport(ERROR, (errmsg("cannot create distributed table "
"concurrently because Citus allows " "concurrently because Citus allows "
"concurrent table distribution only when " "concurrent table distribution only when "
"citus.shard_replication_factor = 1"), "citus.shard_replication_factor = 1"),
errhint("table %s is requested to be colocated " errhint("table %s is requested to be colocated "
"with %s which has " "with %s which has "
"citus.shard_replication_factor > 1", "citus.shard_replication_factor > 1",
get_rel_name(relationId), get_rel_name(relationId),
colocateWithTableName))); colocateWithTableName)));
} }
EnsureColocateWithTableIsValid(relationId, distributionMethod, EnsureColocateWithTableIsValid(relationId, distributionMethod,
distributionColumnName, distributionColumnName,