From 2edd2351254aeef8ad2ff7238fba509fb997c217 Mon Sep 17 00:00:00 2001 From: Daoyuan Wang Date: Wed, 1 Apr 2015 00:29:11 -0700 Subject: [PATCH] fix outputpartitioning --- .../org/apache/spark/sql/execution/joins/SortMergeJoin.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/joins/SortMergeJoin.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/joins/SortMergeJoin.scala index 7048f91f80eab..03cbb680020fd 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/joins/SortMergeJoin.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/joins/SortMergeJoin.scala @@ -39,7 +39,7 @@ case class SortMergeJoin( override def output: Seq[Attribute] = left.output ++ right.output - override def outputPartitioning: Partitioning = left.outputPartitioning + override def outputPartitioning: Partitioning = HashSortedPartitioning(leftKeys, 0) override def requiredChildDistribution: Seq[Distribution] = ClusteredOrderedDistribution(leftKeys) :: ClusteredOrderedDistribution(rightKeys) :: Nil