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 c89b2a068351b..dc7e3a5c41070 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 @@ -182,12 +182,12 @@ private[sql] case class AddExchange(sqlContext: SQLContext) extends Rule[SparkPl case (UnspecifiedDistribution, child) => child case (dist, _) => sys.error(s"Don't know how to ensure $dist") } - val reorderedChildren = operator.requiredInPartitionOrdering.zip(repartitionedChildren).map { - case (Nil, child) => - child - case (ordering, child) => - addSortIfNecessary(ordering, child) - } + val reorderedChildren = + operator.requiredInPartitionOrdering.zip(repartitionedChildren).map { + case (Nil, child) => child + case (ordering, child) => + addSortIfNecessary(ordering, child) + } operator.withNewChildren(reorderedChildren) } } diff --git a/sql/hive/compatibility/src/test/scala/org/apache/spark/sql/hive/execution/SortMergeCompatibilitySuite.scala b/sql/hive/compatibility/src/test/scala/org/apache/spark/sql/hive/execution/SortMergeCompatibilitySuite.scala index 3e08a0ce8c003..bf01fdf1b92e5 100644 --- a/sql/hive/compatibility/src/test/scala/org/apache/spark/sql/hive/execution/SortMergeCompatibilitySuite.scala +++ b/sql/hive/compatibility/src/test/scala/org/apache/spark/sql/hive/execution/SortMergeCompatibilitySuite.scala @@ -142,4 +142,4 @@ class SortMergeCompatibilitySuite extends HiveCompatibilitySuite { "join_reorder4", "join_star" ) -} \ No newline at end of file +}