[SQL] Handle null values in debug()

Author: Michael Armbrust <michael@databricks.com> Closes apache#1646 from marmbrus/nullDebug and squashes the following commits: 49050a8 [Michael Armbrust] Handle null values in debug()
xiliu82 · Jul 30, 2014 · 077f633 · 077f633
1 parent 2e6efca
commit 077f633
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/debug/package.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/debug/package.scala
@@ -105,7 +105,9 @@ package object debug {
             var i = 0
             while (i < numColumns) {
               val value = currentRow(i)
-              columnStats(i).elementTypes += HashSet(value.getClass.getName)
+              if (value != null) {
+                columnStats(i).elementTypes += HashSet(value.getClass.getName)
+              }
               i += 1
             }
             currentRow