predicate fix

apache · May 16, 2015 · 7cc2c64 · 7cc2c64
1 parent 4e61c16
commit 7cc2c64
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/orc/OrcFilters.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/orc/OrcFilters.scala
@@ -99,6 +99,10 @@ private[sql] object OrcFilters extends Logging {
         Some(b1)
       }
       case p@IsNull(attribute: String) => {
+        val b1 = builder.isNull(attribute)
+        Some(b1)
+      }
+      case p@IsNotNull(attribute: String) => {
         val b1 = builder.startNot().isNull(attribute).end()
         Some(b1)
       }