Skip to content

Commit ae2195a

Browse files
committed
Fixes
1 parent 0fef0f8 commit ae2195a

File tree

2 files changed

+3
-1
lines changed

2 files changed

+3
-1
lines changed

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

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -306,6 +306,8 @@ case class UnsafeExternalSort(
306306
override def output: Seq[Attribute] = child.output
307307

308308
override def outputOrdering: Seq[SortOrder] = sortOrder
309+
310+
override def outputsUnsafeRows: Boolean = true
309311
}
310312

311313
@DeveloperApi

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -104,4 +104,4 @@ private[sql] object EnsureRowFormats extends Rule[SparkPlan] {
104104
operator
105105
}
106106
}
107-
}
107+
}

0 commit comments

Comments
 (0)