Github user gatorsmile commented on a diff in the pull request:
https://github.com/apache/spark/pull/21320#discussion_r189489061
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/basicPhysicalOperators.scala
---
@@ -162,7 +162,9 @@ case class FilterExec(condition: Expression, child:
SparkPlan)
val generatedIsNotNullChecks = new Array[Boolean](notNullPreds.length)
val generated = otherPreds.map { c =>
val nullChecks = c.references.map { r =>
- val idx = notNullPreds.indexWhere { n =>
n.asInstanceOf[IsNotNull].child.semanticEquals(r)}
+ val idx = notNullPreds.indexWhere { n =>
+ n.asInstanceOf[IsNotNull].child.references.contains(r)
--- End diff --
Is this change related?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
