Skip to content

Commit 5c95cef

Browse files
author
Patrick Woody
committed
Fix null types
1 parent 83e1e53 commit 5c95cef

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/ColumnStats.scala

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -328,10 +328,10 @@ private[columnar] final class ObjectColumnStats(dataType: DataType) extends Colu
328328
protected var lower: Any = null
329329

330330
val columnType = ColumnType(dataType)
331-
val ordering = if (RowOrdering.isOrderable(dataType)) {
332-
Option(TypeUtils.getInterpretedOrdering(dataType))
333-
} else {
334-
None
331+
val ordering = dataType match {
332+
case x if RowOrdering.isOrderable(dataType) && x != NullType =>
333+
Option(TypeUtils.getInterpretedOrdering(x))
334+
case _ => None
335335
}
336336

337337
override def gatherStats(row: InternalRow, ordinal: Int): Unit = {

0 commit comments

Comments
 (0)