From 3670e82af5b0298190def96a536fba553b745826 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=91=A3=E5=8F=AF=E4=BC=A6?= Date: Wed, 6 Jul 2022 00:08:23 +0800 Subject: [PATCH] [HUDI-4356] Fix the error when sync hive in CTAS (#6029) --- .../sql/hudi/command/CreateHoodieTableAsSelectCommand.scala | 1 + 1 file changed, 1 insertion(+) 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)