Fix InferFiltersFromConstraintsSuite test error

apache · Sep 9, 2018 · 865e0af · 865e0af
1 parent 86b9b78
commit 865e0af
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/...test/scala/org/apache/spark/sql/catalyst/optimizer/InferFiltersFromConstraintsSuite.scala b/...test/scala/org/apache/spark/sql/catalyst/optimizer/InferFiltersFromConstraintsSuite.scala
@@ -196,7 +196,7 @@ class InferFiltersFromConstraintsSuite extends PlanTest {
 
  test("constraints should be inferred from aliased literals") {
  val originalLeft = testRelation.subquery('left).as("left")
- val optimizedLeft = testRelation.subquery('left).where(IsNotNull('a) && 'a === 2).as("left")
+ val optimizedLeft = testRelation.subquery('left).where(IsNotNull('a) && 'a <=> 2).as("left")
 
  val right = Project(Seq(Literal(2).as("two")), testRelation.subquery('right)).as("right")
  val condition = Some("left.a".attr === "right.two".attr)

diff --git a/sql/core/src/test/scala/org/apache/spark/sql/DataFrameSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/DataFrameSuite.scala
@@ -2553,7 +2553,6 @@ class DataFrameSuite extends QueryTest with SharedSQLContext {
  }
 
  test("SPARK-25368 Incorrect predicate pushdown returns wrong result") {
- // This test must disable ConvertToLocalRelation in the test cases, see: SPARK-25267
  def check(newCol: Column, filter: Column, result: Seq[Row]): Unit = {
  val df1 = spark.createDataFrame(Seq(
  (1, 1)