From a553e38250fc617dc7f4619b7afc53a6e28b355c Mon Sep 17 00:00:00 2001 From: Onur Tirtir Date: Mon, 25 Sep 2023 10:55:33 +0300 Subject: [PATCH] style --- .../commands/create_distributed_table.c | 24 +++++++++---------- 1 file changed, 12 insertions(+), 12 deletions(-) diff --git a/src/backend/distributed/commands/create_distributed_table.c b/src/backend/distributed/commands/create_distributed_table.c index 26cf67f97..1e89c6b93 100644 --- a/src/backend/distributed/commands/create_distributed_table.c +++ b/src/backend/distributed/commands/create_distributed_table.c @@ -445,18 +445,18 @@ CreateDistributedTableConcurrently(Oid relationId, char *distributionColumnName, if (!IsColocateWithDefault(colocateWithTableName) && !IsColocateWithNone( colocateWithTableName)) { - if (replicationModel != REPLICATION_MODEL_STREAMING) - { - ereport(ERROR, (errmsg("cannot create distributed table " - "concurrently because Citus allows " - "concurrent table distribution only when " - "citus.shard_replication_factor = 1"), - errhint("table %s is requested to be colocated " - "with %s which has " - "citus.shard_replication_factor > 1", - get_rel_name(relationId), - colocateWithTableName))); - } + if (replicationModel != REPLICATION_MODEL_STREAMING) + { + ereport(ERROR, (errmsg("cannot create distributed table " + "concurrently because Citus allows " + "concurrent table distribution only when " + "citus.shard_replication_factor = 1"), + errhint("table %s is requested to be colocated " + "with %s which has " + "citus.shard_replication_factor > 1", + get_rel_name(relationId), + colocateWithTableName))); + } EnsureColocateWithTableIsValid(relationId, distributionMethod, distributionColumnName,