Skip to content

Commit af189d6

Browse files
committed
Address comments.
1 parent 7db83bc commit af189d6

File tree

1 file changed

+1
-5
lines changed
  • sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer

1 file changed

+1
-5
lines changed

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

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1334,11 +1334,7 @@ object EliminateOuterJoin extends Rule[LogicalPlan] with PredicateHelper {
13341334
val rightConditions = splitConjunctiveConditions
13351335
.filter(_.references.subsetOf(join.right.outputSet))
13361336

1337-
val joinAttributeSet = if (join.condition.isDefined) {
1338-
join.condition.get.references
1339-
} else {
1340-
AttributeSet.empty
1341-
}
1337+
val joinAttributeSet = join.condition.map(_.references).getOrElse(AttributeSet.empty)
13421338
val leftOuterAttributeSet = join.left.outputSet -- joinAttributeSet
13431339
val rightOuterAttributeSet = join.right.outputSet -- joinAttributeSet
13441340
val leftHasNonNullPredicate = leftConditions.exists(canFilterOutNull) ||

0 commit comments

Comments
 (0)