revert unnecessary change

peter-toth · peter-toth · commit 8eca64aed6dd · 2020-06-26T10:42:29.000+02:00
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 =>
