Github user gatorsmile commented on a diff in the pull request:
https://github.com/apache/spark/pull/20020#discussion_r158344919
--- Diff:
sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveStrategies.scala ---
@@ -148,7 +148,8 @@ object HiveAnalysis extends Rule[LogicalPlan] {
override def apply(plan: LogicalPlan): LogicalPlan = plan transformUp {
case InsertIntoTable(r: HiveTableRelation, partSpec, query, overwrite,
ifPartitionNotExists)
if DDLUtils.isHiveTable(r.tableMeta) =>
- InsertIntoHiveTable(r.tableMeta, partSpec, query, overwrite,
ifPartitionNotExists)
+ InsertIntoHiveTable(r.tableMeta, partSpec, query, overwrite,
--- End diff --
Add a `AnalysisBarrier ` here?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
