Skip to content

Commit b42ce1d

Browse files
committed
fix build
1 parent af018be commit b42ce1d

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/PushCNFPredicateThroughJoin.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ import org.apache.spark.sql.catalyst.rules.Rule
3030
*/
3131
object PushCNFPredicateThroughJoin extends Rule[LogicalPlan] with PredicateHelper {
3232
def apply(plan: LogicalPlan): LogicalPlan = plan transform {
33-
case j @ Join(left, right, joinType, Some(joinCondition), hint) if joinType != FullOuter =>
33+
case j @ Join(left, right, joinType, Some(joinCondition), hint) =>
3434
val predicates = conjunctiveNormalForm(joinCondition)
3535
if (predicates.isEmpty) {
3636
j
@@ -53,6 +53,7 @@ object PushCNFPredicateThroughJoin extends Rule[LogicalPlan] with PredicateHelpe
5353
Join(newLeft, right, RightOuter, Some(joinCondition), hint)
5454
case LeftOuter | LeftAnti | ExistenceJoin(_) =>
5555
Join(left, newRight, joinType, Some(joinCondition), hint)
56+
case FullOuter => j
5657
case NaturalJoin(_) => sys.error("Untransformed NaturalJoin node")
5758
case UsingJoin(_, _) => sys.error("Untransformed Using join node")
5859
}

0 commit comments

Comments
 (0)