diff --git a/hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/CreateHoodieTableAsSelectCommand.scala b/hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/CreateHoodieTableAsSelectCommand.scala index a4d0fa04a..0c8714b7b 100644 --- a/hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/CreateHoodieTableAsSelectCommand.scala +++ b/hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/CreateHoodieTableAsSelectCommand.scala @@ -76,6 +76,7 @@ case class CreateHoodieTableAsSelectCommand( table.storage.compressed, table.storage.properties.--(needFilterProps)) val newTable = table.copy( + identifier = tableIdentWithDB, storage = newStorage, schema = reOrderedQuery.schema, properties = table.properties.--(needFilterProps)