diff --git a/src/backend/distributed/commands/create_distributed_table.c b/src/backend/distributed/commands/create_distributed_table.c index 55f1b67d6..bfa1dbcf2 100644 --- a/src/backend/distributed/commands/create_distributed_table.c +++ b/src/backend/distributed/commands/create_distributed_table.c @@ -1423,15 +1423,10 @@ DecideReplicationModel(char distributionMethod, char *colocateWithTableName) return replicationModel; } - else if (distributionMethod == DISTRIBUTE_BY_HASH && - !DistributedTableReplicationIsEnabled()) + else if (distributionMethod == DISTRIBUTE_BY_HASH) { return REPLICATION_MODEL_STREAMING; } - else - { - return REPLICATION_MODEL_COORDINATOR; - } /* we should not reach to this point */ return REPLICATION_MODEL_INVALID; diff --git a/src/backend/distributed/metadata/metadata_sync.c b/src/backend/distributed/metadata/metadata_sync.c index ff9300152..2ae36aefd 100644 --- a/src/backend/distributed/metadata/metadata_sync.c +++ b/src/backend/distributed/metadata/metadata_sync.c @@ -3173,8 +3173,7 @@ EnsurePartitionMetadataIsSane(Oid relationId, char distributionMethod, int coloc if (!(replicationModel == REPLICATION_MODEL_2PC || - replicationModel == REPLICATION_MODEL_STREAMING || - replicationModel == REPLICATION_MODEL_COORDINATOR)) + replicationModel == REPLICATION_MODEL_STREAMING)) { ereport(ERROR, (errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE), errmsg("Metadata syncing is only allowed for " diff --git a/src/backend/distributed/shared_library_init.c b/src/backend/distributed/shared_library_init.c index ea1f33810..06c6d8908 100644 --- a/src/backend/distributed/shared_library_init.c +++ b/src/backend/distributed/shared_library_init.c @@ -227,7 +227,6 @@ static const struct config_enum_entry task_assignment_policy_options[] = { }; static const struct config_enum_entry replication_model_options[] = { - { "statement", REPLICATION_MODEL_COORDINATOR, false }, { "streaming", REPLICATION_MODEL_STREAMING, false }, { NULL, 0, false } }; diff --git a/src/include/distributed/pg_dist_partition.h b/src/include/distributed/pg_dist_partition.h index 032cc195a..eab3954a1 100644 --- a/src/include/distributed/pg_dist_partition.h +++ b/src/include/distributed/pg_dist_partition.h @@ -63,7 +63,6 @@ typedef FormData_pg_dist_partition *Form_pg_dist_partition; * and 't' for two-phase-commit. We also use an invalid replication model * ('i') for distinguishing uninitialized variables where necessary. */ -#define REPLICATION_MODEL_COORDINATOR 'c' #define REPLICATION_MODEL_STREAMING 's' #define REPLICATION_MODEL_2PC 't' #define REPLICATION_MODEL_INVALID 'i'