File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
sql/core/src/main/scala/org/apache/spark/sql/execution/joins Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -50,16 +50,16 @@ case class ShuffledHashOuterJoin(
5050 override def outputPartitioning : Partitioning = joinType match {
5151 case LeftOuter =>
5252 val partitions =
53- Seq (left.outputPartitioning, right.outputPartitioning.withNullSafeSetting(true ))
53+ Seq (left.outputPartitioning, right.outputPartitioning.withNullSafeSetting(false ))
5454 PartitioningCollection (partitions)
5555 case RightOuter =>
5656 val partitions =
57- Seq (right.outputPartitioning, left.outputPartitioning.withNullSafeSetting(true ))
57+ Seq (right.outputPartitioning, left.outputPartitioning.withNullSafeSetting(false ))
5858 PartitioningCollection (partitions)
5959 case FullOuter =>
6060 val partitions =
61- Seq (left.outputPartitioning.withNullSafeSetting(true ),
62- right.outputPartitioning.withNullSafeSetting(true ))
61+ Seq (left.outputPartitioning.withNullSafeSetting(false ),
62+ right.outputPartitioning.withNullSafeSetting(false ))
6363 PartitioningCollection (partitions)
6464 case x =>
6565 throw new IllegalArgumentException (s " HashOuterJoin should not take $x as the JoinType " )
You can’t perform that action at this time.
0 commit comments