We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a9eb7de commit 7796e5cCopy full SHA for 7796e5c
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/Optimizer.scala
@@ -1239,7 +1239,6 @@ object InferFiltersFromConstraints extends Rule[LogicalPlan]
1239
val rightKeys = new mutable.HashSet[Expression]
1240
conditionOpt.foreach { condition =>
1241
splitConjunctivePredicates(condition).foreach {
1242
- case EqualTo(l, r) if l.references.isEmpty || r.references.isEmpty =>
1243
case EqualTo(l, r) =>
1244
if (resultMayBeNull(l)) {
1245
if (canEvaluate(l, left)) leftKeys.add(l)
0 commit comments