diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala index 7848f88bda1c9..b19d4588233df 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala @@ -825,7 +825,6 @@ class Analyzer( result case UnresolvedExtractValue(child, fieldExpr) if child.resolved => ExtractValue(child, fieldExpr, resolver) - case _ => e.mapChildren(resolve(_, q)) } def apply(plan: LogicalPlan): LogicalPlan = plan.transformUp { diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/trees/TreeNode.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/trees/TreeNode.scala index 9c7d47f99ee10..e841225b854ec 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/trees/TreeNode.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/trees/TreeNode.scala @@ -184,7 +184,9 @@ abstract class TreeNode[BaseType <: TreeNode[BaseType]] extends Product { val arr = Array.ofDim[B](productArity) var i = 0 while (i < arr.length) { - arr(i) = f(productElement(i)) + CurrentOrigin.withOrigin(origin) { + arr(i) = f(productElement(i)) + } i += 1 } arr