propagate rowOrdering for RangePartitioning

apache · Apr 15, 2015 · 5049d88 · 5049d88
1 parent f91a2ae
commit 5049d88
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/Exchange.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/Exchange.scala
@@ -255,7 +255,7 @@ private[sql] case class EnsureRequirements(sqlContext: SQLContext) extends Rule[
           case (ClusteredDistribution(clustering), rowOrdering, child) =>
             addOperatorsIfNecessary(HashPartitioning(clustering, numPartitions), rowOrdering, child)
           case (OrderedDistribution(ordering), rowOrdering, child) =>
-            addOperatorsIfNecessary(RangePartitioning(ordering, numPartitions), Nil, child)
+            addOperatorsIfNecessary(RangePartitioning(ordering, numPartitions), rowOrdering, child)
 
           case (UnspecifiedDistribution, Seq(), child) =>
             child