Update HiveStrategies.scala

markhamstra · Dec 2, 2014 · e572b9a · e572b9a
1 parent 6e643f8
commit e572b9a
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveStrategies.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveStrategies.scala
@@ -194,8 +194,10 @@ private[hive] trait HiveStrategies {
         // Filter out all predicates that only deal with partition keys, these are given to the
         // hive table scan operator to be used for partition pruning.
         val partitionKeyIds = AttributeSet(relation.partitionKeys)
-        val (pruningPredicates, otherPredicates) = predicates.partition {
-          _.references.subsetOf(partitionKeyIds)
+        val (pruningPredicates, otherPredicates) = predicates.partition { x =>
+          x.references.baseSet != null &&
+          !x.references.baseSet.isEmpty &&
+          x.references.subsetOf(partitionKeyIds)
         }
 
         pruneFilterProject(