Skip to content

Commit 2788441

Browse files
authored
Revert "transformexpression with origin" (apache-spark-on-k8s#350)
1 parent 78b34b4 commit 2788441

File tree

1 file changed

+2
-2
lines changed
  • sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans

1 file changed

+2
-2
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/QueryPlan.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@
1818
package org.apache.spark.sql.catalyst.plans
1919

2020
import org.apache.spark.sql.catalyst.expressions._
21-
import org.apache.spark.sql.catalyst.trees.{CurrentOrigin, TreeNode}
21+
import org.apache.spark.sql.catalyst.trees.TreeNode
2222
import org.apache.spark.sql.internal.SQLConf
2323
import org.apache.spark.sql.types.{DataType, StructType}
2424

@@ -103,7 +103,7 @@ abstract class QueryPlan[PlanType <: QueryPlan[PlanType]] extends TreeNode[PlanT
103103
var changed = false
104104

105105
@inline def transformExpression(e: Expression): Expression = {
106-
val newE = CurrentOrigin.withOrigin(e.origin) { f(e) }
106+
val newE = f(e)
107107
if (newE.fastEquals(e)) {
108108
e
109109
} else {

0 commit comments

Comments
 (0)