Github user ueshin commented on a diff in the pull request:

    https://github.com/apache/spark/pull/21745#discussion_r201619815
  
    --- Diff: 
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala
 ---
    @@ -1163,7 +1163,8 @@ class Analyzer(
               case p: Project =>
                 val maybeResolvedExprs = exprs.map(resolveExpression(_, p))
                 val (newExprs, newChild) = 
resolveExprsAndAddMissingAttrs(maybeResolvedExprs, p.child)
    -            val missingAttrs = AttributeSet(newExprs) -- 
AttributeSet(maybeResolvedExprs)
    +            val missingAttrs = AttributeSet(newExprs) --
    --- End diff --
    
    We should also fix in `Aggregate` case?


---

---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org

Reply via email to