Commit 018ae58 1 parent 492e074 commit 018ae58 Copy full SHA for 018ae58
File tree 1 file changed +2
-2
lines changed
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer
1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -111,8 +111,8 @@ abstract class PropagateEmptyRelationBase extends Rule[LogicalPlan] with CastSup
111
111
// Except is handled as LeftAnti by `ReplaceExceptWithAntiJoin` rule.
112
112
case LeftOuter | LeftSemi | LeftAnti if isLeftEmpty => empty(p)
113
113
case LeftSemi if isRightEmpty | isFalseCondition => empty(p)
114
- case LeftAnti if isRightEmpty && canExecuteWithoutJoin(p.left) => p.left
115
- case LeftAnti if isFalseCondition && canExecuteWithoutJoin(p.left) => p.left
114
+ case LeftAnti if ( isRightEmpty | isFalseCondition) && canExecuteWithoutJoin(p.left) =>
115
+ p.left
116
116
case FullOuter if isLeftEmpty && isRightEmpty => empty(p)
117
117
case LeftOuter | FullOuter if isRightEmpty && canExecuteWithoutJoin(p.left) =>
118
118
Project (p.left.output ++ nullValueProjectList(p.right), p.left)
You can’t perform that action at this time.
0 commit comments