From 5049d882fbfcf9b7c63e95ec20d3a15310068752 Mon Sep 17 00:00:00 2001 From: Daoyuan Wang Date: Tue, 14 Apr 2015 23:33:58 -0700 Subject: [PATCH] propagate rowOrdering for RangePartitioning --- .../main/scala/org/apache/spark/sql/execution/Exchange.scala | 2 +- 1 file changed, 1 insertion(+), 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 index 2599765f24aa5..518fc9e57c708 100644 --- 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