external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Move supported identity column check to EnsureRelationCanBeDistributed()

issue/6694
Gokhan Gulbiz 2023-03-10 11:18:55 +03:00
parent 4fb37f33cc
commit 3311b44e6a
No known key found for this signature in database
GPG Key ID: 608EF06B6BD1B45B
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/backend/distributed/commands/create_distributed_table.c
View File

@ -438,8 +438,6 @@ CreateDistributedTableConcurrently(Oid relationId, char *distributionColumnName,
WarnIfTableHaveNoReplicaIdentity(relationId); WarnIfTableHaveNoReplicaIdentity(relationId);
ErrorIfTableHasUnsupportedIdentityColumn(relationId);
List *shardList = LoadShardIntervalList(relationId); List *shardList = LoadShardIntervalList(relationId);
/* /*
@ -1014,8 +1012,6 @@ CreateCitusTable(Oid relationId, char *distributionColumnName,
bool shardCountIsStrict, char *colocateWithTableName, bool shardCountIsStrict, char *colocateWithTableName,
char replicationModel) char replicationModel)
{ {
ErrorIfTableHasUnsupportedIdentityColumn(relationId);
/* /*
* EnsureTableNotDistributed errors out when relation is a citus table but * EnsureTableNotDistributed errors out when relation is a citus table but
* we don't want to ask user to first undistribute their citus local tables * we don't want to ask user to first undistribute their citus local tables
@ -1673,6 +1669,8 @@ EnsureRelationCanBeDistributed(Oid relationId, Var *distributionColumn,
{ {
Oid parentRelationId = InvalidOid; Oid parentRelationId = InvalidOid;
ErrorIfTableHasUnsupportedIdentityColumn(relationId);
EnsureLocalTableEmptyIfNecessary(relationId, distributionMethod); EnsureLocalTableEmptyIfNecessary(relationId, distributionMethod);
/* user really wants triggers? */ /* user really wants triggers? */