Skip to content

Commit 6e95e37

Browse files
committed
fix UT
1 parent 4e441f8 commit 6e95e37

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

sql/core/src/test/scala/org/apache/spark/sql/execution/columnar/InMemoryColumnarQuerySuite.scala

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,7 @@ import java.sql.{Date, Timestamp}
2222

2323
import org.apache.spark.sql.{DataFrame, QueryTest, Row}
2424
import org.apache.spark.sql.catalyst.expressions.{AttributeReference, AttributeSet, In}
25+
import org.apache.spark.sql.catalyst.plans.logical.LocalRelation
2526
import org.apache.spark.sql.catalyst.plans.physical.HashPartitioning
2627
import org.apache.spark.sql.execution.{FilterExec, LocalTableScanExec, WholeStageCodegenExec}
2728
import 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

Comments
 (0)