Make the condition better

apache · Nov 5, 2016 · c0667d1 · c0667d1
1 parent 4132075
commit c0667d1
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/csv/CSVInferSchema.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/csv/CSVInferSchema.scala
@@ -231,8 +231,8 @@ private[csv] object CSVTypeCast {
       castType: DataType,
       nullable: Boolean = true,
       options: CSVOptions = CSVOptions()): Any = {
-
-    if (datum == null || nullable && datum == options.nullValue) {
+    val isNull = datum == options.nullValue || datum == null
+    if (nullable && isNull) {
       null
     } else {
       castType match {