File tree Expand file tree Collapse file tree 1 file changed +2
-3
lines changed
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis Expand file tree Collapse file tree 1 file changed +2
-3
lines changed Original file line number Diff line number Diff line change @@ -596,7 +596,6 @@ class Analyzer(
596596 return plan
597597 }
598598 plan match {
599- //
600599 case p : Project =>
601600 val missing = missingAttrs -- p.child.outputSet
602601 Project (p.projectList ++ missingAttrs, addMissingAttr(p.child, missing))
@@ -614,8 +613,8 @@ class Analyzer(
614613 }
615614 val newAggregateExpressions = a.aggregateExpressions ++ missingAttrs
616615 a.copy(aggregateExpressions = newAggregateExpressions)
617- case f : UnaryNode =>
618- addMissingAttr(f .child, missingAttrs)
616+ case u : UnaryNode =>
617+ u.withNewChildren( addMissingAttr(u .child, missingAttrs) :: Nil )
619618 case other =>
620619 throw new AnalysisException (s " Can't add $missingAttrs to $other" )
621620 }
You can’t perform that action at this time.
0 commit comments