Skip to content

Commit 2edd235

Browse files
committed
fix outputpartitioning
1 parent 57baa40 commit 2edd235

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/joins/SortMergeJoin.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ case class SortMergeJoin(
3939

4040
override def output: Seq[Attribute] = left.output ++ right.output
4141

42-
override def outputPartitioning: Partitioning = left.outputPartitioning
42+
override def outputPartitioning: Partitioning = HashSortedPartitioning(leftKeys, 0)
4343

4444
override def requiredChildDistribution: Seq[Distribution] =
4545
ClusteredOrderedDistribution(leftKeys) :: ClusteredOrderedDistribution(rightKeys) :: Nil

0 commit comments

Comments
 (0)