Remove unnecessary Project.

apache · Aug 31, 2020 · 5db1e0f · 5db1e0f
1 parent 95e8fd4
commit 5db1e0f
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveUnion.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/ResolveUnion.scala
@@ -139,7 +139,11 @@ object ResolveUnion extends Rule[LogicalPlan] {
     val leftChild = if (allowMissingCol) {
       // Add missing (nested) fields to left plan.
       val (leftProjectList, _) = compareAndAddFields(rightChild, left, allowMissingCol)
-      Project(leftProjectList, left)
+      if (leftProjectList.map(_.toAttribute) != left.output) {
+        Project(leftProjectList, left)
+      } else {
+        left
+      }
     } else {
       left
     }