diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/joins/SortMergeJoin.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/joins/SortMergeJoin.scala index 048251c4c1f91..8262a3c14b0b3 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/joins/SortMergeJoin.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/joins/SortMergeJoin.scala @@ -47,7 +47,8 @@ case class SortMergeJoin( ClusteredDistribution(leftKeys) :: ClusteredDistribution(rightKeys) :: Nil // this is to manually construct an ordering that can be used to compare keys from both sides - private val keyOrdering: RowOrdering = RowOrdering.getOrderingFromDataTypes(leftKeys.map(_.dataType)) + private val keyOrdering: RowOrdering = + RowOrdering.getOrderingFromDataTypes(leftKeys.map(_.dataType)) private def requiredOrders(keys: Seq[Expression], side: SparkPlan): Ordering[Row] = newOrdering(keys.map(SortOrder(_, Ascending)), side.output)