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 c859b60 commit b9dbb9cCopy full SHA for b9dbb9c
sql/core/src/main/scala/org/apache/spark/sql/Dataset.scala
@@ -1729,7 +1729,7 @@ class Dataset[T] private[sql](
1729
// ordering deterministic. Note that MapTypes cannot be sorted and are explicitly pruned out
1730
// from the sort order.
1731
val sortOrder = logicalPlan.output
1732
- .filterNot(_.dataType.existsRecursively(dt => dt.isInstanceOf[MapType]))
+ .filter(attr => RowOrdering.isOrderable(attr.dataType))
1733
.map(SortOrder(_, Ascending))
1734
val plan = if (sortOrder.nonEmpty) {
1735
Sort(sortOrder, global = false, logicalPlan)
0 commit comments