[SPARK-25150][SQL] Fix review findings 5

apache · Sep 6, 2018 · 938bd7f · 938bd7f
1 parent 3f15aab
commit 938bd7f
Showing 1 changed file with 1 addition and 2 deletions.
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
@@ -754,7 +754,6 @@ class Analyzer(
    * a logical plan node's children.
    */
   object ResolveReferences extends Rule[LogicalPlan] {
-
     private val emptyAttrMap = new AttributeMap[Attribute](Map.empty)
 
     /**
@@ -930,7 +929,7 @@ class Analyzer(
       case j @ Join(left, right, _, condition) if !j.duplicateResolved =>
         val (dedupedRight, attributeRewrites) = dedupRight(left, right)
         val changedCondition = condition.map(_.transform {
-          case attr: Attribute if attr.resolved => attributeRewrites.getOrElse(attr, attr)
+          case attr: Attribute if attr.resolved => dedupAttr(attr, attributeRewrites)
         })
         j.copy(right = dedupedRight, condition = changedCondition)
       case i @ Intersect(left, right, _) if !i.duplicateResolved =>