File tree Expand file tree Collapse file tree 2 files changed +1
-3
lines changed
sql/core/src/main/scala/org/apache/spark/sql/execution Expand file tree Collapse file tree 2 files changed +1
-3
lines changed Original file line number Diff line number Diff line change @@ -188,7 +188,6 @@ private[sql] case class EnsureRequirements(sqlContext: SQLContext) extends Rule[
188188 case (required, child) => required.nonEmpty && required != child
189189 }
190190
191-
192191 // True iff outputPartitionings of children are compatible with each other.
193192 // It is possible that every child satisfies its required data distribution
194193 // but two children have incompatible outputPartitionings. For example,
Original file line number Diff line number Diff line change @@ -47,8 +47,7 @@ case class SortMergeJoin(
4747 ClusteredDistribution (leftKeys) :: ClusteredDistribution (rightKeys) :: Nil
4848
4949 // this is to manually construct an ordering that can be used to compare keys from both sides
50- private val keyOrdering : RowOrdering =
51- RowOrdering .forSchema(leftKeys.map(_.dataType))
50+ private val keyOrdering : RowOrdering = RowOrdering .forSchema(leftKeys.map(_.dataType))
5251
5352 override def outputOrdering : Seq [SortOrder ] = requiredOrders(leftKeys)
5453
You can’t perform that action at this time.
0 commit comments