Skip to content

Commit 013f97a

Browse files
committed
Fix PlannerSuite and ParquetFilterSuite
1 parent 80dab7e commit 013f97a

File tree

2 files changed

+3
-5
lines changed

2 files changed

+3
-5
lines changed

sql/core/src/test/scala/org/apache/spark/sql/execution/PlannerSuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -159,7 +159,7 @@ class PlannerSuite extends SharedSQLContext {
159159

160160
withTempTable("testPushed") {
161161
val exp = sql("select * from testPushed where key = 15").queryExecution.sparkPlan
162-
assert(exp.toString.contains("PushedFilters: [EqualTo(key,15)]"))
162+
assert(exp.toString.contains("PushedFilters: [IsNotNull(key), EqualTo(key,15)]"))
163163
}
164164
}
165165
}

sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetFilterSuite.scala

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -74,10 +74,8 @@ class ParquetFilterSuite extends QueryTest with ParquetTest with SharedSQLContex
7474
selectedFilters.foreach { pred =>
7575
val maybeFilter = ParquetFilters.createFilter(df.schema, pred)
7676
assert(maybeFilter.isDefined, s"Couldn't generate filter predicate for $pred")
77-
maybeFilter.foreach { f =>
78-
// Doesn't bother checking type parameters here (e.g. `Eq[Integer]`)
79-
assert(f.getClass === filterClass)
80-
}
77+
// Doesn't bother checking type parameters here (e.g. `Eq[Integer]`)
78+
maybeFilter.exists(_.getClass === filterClass)
8179
}
8280
checker(stripSparkFilter(query), expected)
8381
}

0 commit comments

Comments
 (0)