revert unnecessary change

apache · Jun 26, 2020 · 8eca64a · 8eca64a
1 parent dbd8606
commit 8eca64a
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/QueryPlan.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/QueryPlan.scala
@@ -336,13 +336,12 @@ object QueryPlan extends PredicateHelper {
    * `Attribute`, and replace it with `BoundReference` will cause error.
    */
   def normalizeExpressions[T <: Expression](e: T, input: AttributeSeq): T = {
-    type T2 = QueryPlan[_]
     e.transformUp {
-      case s: PlanExpression[T2 @unchecked] =>
+      case s: PlanExpression[QueryPlan[_] @unchecked] =>
         // Normalize the outer references in the subquery plan.
         val normalizedPlan = s.plan.transformAllExpressions {
           case OuterReference(r) => OuterReference(QueryPlan.normalizeExpressions(r, input))
-        }.canonicalized.asInstanceOf[T2]
+        }.canonicalized
         s.withNewPlan(normalizedPlan)
 
       case ar: AttributeReference =>