File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -103,7 +103,7 @@ abstract class QueryPlan[PlanType <: QueryPlan[PlanType]] extends TreeNode[PlanT
103
103
var changed = false
104
104
105
105
@ inline def transformExpression (e : Expression ): Expression = {
106
- val newE = f(e)
106
+ val newE = CurrentOrigin .withOrigin(e.origin) { f(e) }
107
107
if (newE.fastEquals(e)) {
108
108
e
109
109
} else {
@@ -122,7 +122,7 @@ abstract class QueryPlan[PlanType <: QueryPlan[PlanType]] extends TreeNode[PlanT
122
122
case null => null
123
123
}
124
124
125
- val newArgs = CurrentOrigin .withOrigin(origin) { mapProductIterator(recursiveTransform) }
125
+ val newArgs = mapProductIterator(recursiveTransform)
126
126
127
127
if (changed) makeCopy(newArgs).asInstanceOf [this .type ] else this
128
128
}
You can’t perform that action at this time.
0 commit comments