Skip to content

Commit a28277f

Browse files
committed
fix style
1 parent 645c70b commit a28277f

File tree

2 files changed

+7
-7
lines changed

2 files changed

+7
-7
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/Exchange.scala

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -182,12 +182,12 @@ private[sql] case class AddExchange(sqlContext: SQLContext) extends Rule[SparkPl
182182
case (UnspecifiedDistribution, child) => child
183183
case (dist, _) => sys.error(s"Don't know how to ensure $dist")
184184
}
185-
val reorderedChildren = operator.requiredInPartitionOrdering.zip(repartitionedChildren).map {
186-
case (Nil, child) =>
187-
child
188-
case (ordering, child) =>
189-
addSortIfNecessary(ordering, child)
190-
}
185+
val reorderedChildren =
186+
operator.requiredInPartitionOrdering.zip(repartitionedChildren).map {
187+
case (Nil, child) => child
188+
case (ordering, child) =>
189+
addSortIfNecessary(ordering, child)
190+
}
191191
operator.withNewChildren(reorderedChildren)
192192
}
193193
}

sql/hive/compatibility/src/test/scala/org/apache/spark/sql/hive/execution/SortMergeCompatibilitySuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -142,4 +142,4 @@ class SortMergeCompatibilitySuite extends HiveCompatibilitySuite {
142142
"join_reorder4",
143143
"join_star"
144144
)
145-
}
145+
}

0 commit comments

Comments
 (0)