bug fix

Davies Liu · Davies Liu · commit d6bba37147fe · 2017-01-19T10:23:50.000-08:00
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/predicates.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/predicates.scala
@@ -93,6 +93,7 @@ trait PredicateHelper {
     case e: SubqueryExpression =>
       // non-correlated subquery will be replaced as literal
       e.children.isEmpty
+    case a: AttributeReference => true
     case e: Unevaluable => false
     case e => e.children.forall(canEvaluateWithinJoin)
   }

Original file line number	Diff line number	Diff line change
`@@ -93,6 +93,7 @@ trait PredicateHelper {`
`93`	`93`	`case e: SubqueryExpression =>`
`94`	`94`	`// non-correlated subquery will be replaced as literal`
`95`	`95`	`e.children.isEmpty`
	`96`	`+ case a: AttributeReference => true`
`96`	`97`	`case e: Unevaluable => false`
`97`	`98`	`case e => e.children.forall(canEvaluateWithinJoin)`
`98`	`99`	`}`