w

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;

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 "

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 }
 };

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'