1 files changed, 2 insertions, 2 deletions
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/command/views.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/command/views.scala
index 7542f9d6c3..07cc4a9482 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/execution/command/views.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/command/views.scala
@@ -144,11 +144,11 @@ case class CreateViewCommand(
     val viewSchema: Seq[CatalogColumn] = {
       if (tableDesc.schema.isEmpty) {
         analyzedPlan.output.map { a =>
-          CatalogColumn(a.name, a.dataType.simpleString)
+          CatalogColumn(a.name, a.dataType.catalogString)
         }
       } else {
         analyzedPlan.output.zip(tableDesc.schema).map { case (a, col) =>
-          CatalogColumn(col.name, a.dataType.simpleString, nullable = true, col.comment)
+          CatalogColumn(col.name, a.dataType.catalogString, nullable = true, col.comment)
         }
       }
     }