diff --git a/src/backend/distributed/commands/create_distributed_table.c b/src/backend/distributed/commands/create_distributed_table.c
index e3c02e2b8..931471b55 100644
--- a/src/backend/distributed/commands/create_distributed_table.c
+++ b/src/backend/distributed/commands/create_distributed_table.c
@@ -436,7 +436,7 @@ CreateDistributedTableConcurrently(Oid relationId, char *distributionColumnName,
 
 	char replicationModel = DecideDistTableReplicationModel(distributionMethod,
 															colocateWithTableName);
-	if (replicationModel == REPLICATION_MODEL_COORDINATOR)
+	if (replicationModel != REPLICATION_MODEL_STREAMING)
 	{
 		ereport(ERROR, (errmsg("cannot create a replicated distributed "
 							   "table concurrently")));