[HUDI-4356] Fix the error when sync hive in CTAS (#6029)

2022-07-06 00:08:23 +08:00
parent 8570c3aab4
commit 3670e82af5
1 changed files with 1 additions and 0 deletions
--- 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)