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 index 8e73f9181f08b..0a9924b139a48 100644 --- 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) }