We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 55221fa commit a240707Copy full SHA for a240707
sql/core/src/main/scala/org/apache/spark/sql/execution/SparkStrategies.scala
@@ -93,11 +93,11 @@ private[sql] abstract class SparkStrategies extends QueryPlanner[SparkPlan] {
93
private[this] def isValidSort(
94
leftKeys: Seq[Expression],
95
rightKeys: Seq[Expression]): Boolean = {
96
- !leftKeys.zip(rightKeys).exists { keys =>
+ leftKeys.zip(rightKeys).forall { keys =>
97
(keys._1.dataType, keys._2.dataType) match {
98
- case (l: AtomicType, r: AtomicType) => false
99
- case (NullType, NullType) => false
100
- case _ => true
+ case (l: AtomicType, r: AtomicType) => true
+ case (NullType, NullType) => true
+ case _ => false
101
}
102
103
0 commit comments