@@ -22,6 +22,7 @@ import java.sql.{Date, Timestamp}
2222
2323import org .apache .spark .sql .{DataFrame , QueryTest , Row }
2424import org .apache .spark .sql .catalyst .expressions .{AttributeReference , AttributeSet , In }
25+ import org .apache .spark .sql .catalyst .plans .logical .LocalRelation
2526import org .apache .spark .sql .catalyst .plans .physical .HashPartitioning
2627import org .apache .spark .sql .execution .{FilterExec , LocalTableScanExec , WholeStageCodegenExec }
2728import org .apache .spark .sql .functions ._
@@ -455,7 +456,8 @@ class InMemoryColumnarQuerySuite extends QueryTest with SharedSQLContext {
455456 test(" SPARK-22249: buildFilter should not throw exception when In contains an empty list" ) {
456457 val attribute = AttributeReference (" a" , IntegerType )()
457458 val localTableScanExec = LocalTableScanExec (Seq (attribute), Nil )
458- val testRelation = InMemoryRelation (false , 1 , MEMORY_ONLY , localTableScanExec, None , null )
459+ val testRelation = InMemoryRelation (false , 1 , MEMORY_ONLY , localTableScanExec, None ,
460+ LocalRelation (Seq (attribute), Nil ))
459461 val tableScanExec = InMemoryTableScanExec (Seq (attribute),
460462 Seq (In (attribute, Nil )), testRelation)
461463 assert(tableScanExec.partitionFilters.isEmpty)
0 commit comments