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 2abbf8e commit 5d54349Copy full SHA for 5d54349
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/Optimizer.scala
@@ -362,7 +362,7 @@ object NormalizeFilters extends Rule[LogicalPlan] with PredicateHelper {
362
case Or(lhs, rhs) if lhs fastEquals rhs => lhs :: Nil
363
// a && a => a
364
case And(lhs, rhs) if lhs fastEquals rhs => lhs :: Nil
365
- // (a || b || c || ...) && (a || b || d || ...) => a && b && (c || d || ...)
+ // (a && b && c && ...) || (a && b && d && ...) => a && b && (c || d || ...)
366
case Or(lhs, rhs) =>
367
val lhsSet = splitConjunctivePredicates(lhs).toSet
368
val rhsSet = splitConjunctivePredicates(rhs).toSet
0 commit comments