fix style

marmbrus · Apr 10, 2015 · a28277f · a28277f
1 parent 645c70b
commit a28277f
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 7 deletions.
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
@@ -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/...lity/src/test/scala/org/apache/spark/sql/hive/execution/SortMergeCompatibilitySuite.scala b/...lity/src/test/scala/org/apache/spark/sql/hive/execution/SortMergeCompatibilitySuite.scala
@@ -142,4 +142,4 @@ class SortMergeCompatibilitySuite extends HiveCompatibilitySuite {
     "join_reorder4",
     "join_star"
   )
-}
+}