Skip to content

Commit c7eaaa2

Browse files
committed
Revert modification to PushDownLeftSemiAntiJoin rule
1 parent d991a02 commit c7eaaa2

File tree

1 file changed

+1
-4
lines changed

1 file changed

+1
-4
lines changed

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

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -69,10 +69,7 @@ object PushDownLeftSemiAntiJoin extends Rule[LogicalPlan]
6969
val canPushDownPredicate = (predicate: Expression) => {
7070
val replaced = replaceAlias(predicate, aliasMap)
7171
predicate.references.nonEmpty &&
72-
replaced.references.subsetOf(agg.child.outputSet ++ rightOp.outputSet) &&
73-
// references must not be ambiguous (i.e., not contained in both sides)
74-
!replaced.references.exists(attr =>
75-
agg.child.outputSet.contains(attr) && rightOp.outputSet.contains(attr))
72+
replaced.references.subsetOf(agg.child.outputSet ++ rightOp.outputSet)
7673
}
7774
val makeJoinCondition = (predicates: Seq[Expression]) => {
7875
replaceAlias(predicates.reduce(And), aliasMap)

0 commit comments

Comments
 (0)