Skip to content

Commit 49050a8

Browse files
committed
Handle null values in debug()
1 parent 2c35666 commit 49050a8

File tree

1 file changed

+3
-1
lines changed
  • sql/core/src/main/scala/org/apache/spark/sql/execution/debug

1 file changed

+3
-1
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/debug/package.scala

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -107,7 +107,9 @@ package object debug {
107107
var i = 0
108108
while (i < numColumns) {
109109
val value = currentRow(i)
110-
columnStats(i).elementTypes += HashSet(value.getClass.getName)
110+
if (value != null) {
111+
columnStats(i).elementTypes += HashSet(value.getClass.getName)
112+
}
111113
i += 1
112114
}
113115
currentRow

0 commit comments

Comments
 (0)