Github user viirya commented on a diff in the pull request:
https://github.com/apache/spark/pull/20521#discussion_r217255531
--- Diff:
sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/CreateHiveTableAsSelectCommand.scala
---
@@ -56,34 +57,36 @@ case class CreateHiveTableAsSelectCommand(
return Seq.empty
}
- sparkSession.sessionState.executePlan(
- InsertIntoTable(
- UnresolvedRelation(tableIdentifier),
- Map(),
- query,
- overwrite = false,
- ifPartitionNotExists = false)).toRdd
+ InsertIntoHiveTable(
--- End diff --
Ok. I see. Thanks.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
