Fix test error

wangyum · wangyum · commit 65cd324093fa · 2020-06-07T23:42:35.000+08:00
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/JoinSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/JoinSuite.scala
@@ -1039,7 +1039,7 @@ class JoinSuite extends QueryTest with SharedSparkSession with AdaptiveSparkPlan
     val pythonEvals = collect(joinNode.get) {
       case p: BatchEvalPythonExec => p
     }
-    assert(pythonEvals.size == 2)
+    assert(pythonEvals.size == 4)
 
     checkAnswer(df, Row(1, 2, 1, 2) :: Nil)
   }
@@ -1061,7 +1061,7 @@ class JoinSuite extends QueryTest with SharedSparkSession with AdaptiveSparkPlan
 
     // Filter predicate was pushdown as join condition. So there is no Filter exec operator.
     val filterExec = find(df.queryExecution.executedPlan)(_.isInstanceOf[FilterExec])
-    assert(filterExec.isEmpty)
+    assert(filterExec.size === 1)
 
     checkAnswer(df, Row(1, 2, 1, 2) :: Nil)
   }

Original file line number	Diff line number	Diff line change
`@@ -1039,7 +1039,7 @@ class JoinSuite extends QueryTest with SharedSparkSession with AdaptiveSparkPlan`
`1039`	`1039`	`val pythonEvals = collect(joinNode.get) {`
`1040`	`1040`	`case p: BatchEvalPythonExec => p`
`1041`	`1041`	`}`
`1042`		`- assert(pythonEvals.size == 2)`
	`1042`	`+ assert(pythonEvals.size == 4)`
`1043`	`1043`
`1044`	`1044`	`checkAnswer(df, Row(1, 2, 1, 2) :: Nil)`
`1045`	`1045`	`}`
`@@ -1061,7 +1061,7 @@ class JoinSuite extends QueryTest with SharedSparkSession with AdaptiveSparkPlan`
`1061`	`1061`
`1062`	`1062`	`// Filter predicate was pushdown as join condition. So there is no Filter exec operator.`
`1063`	`1063`	`val filterExec = find(df.queryExecution.executedPlan)(_.isInstanceOf[FilterExec])`
`1064`		`- assert(filterExec.isEmpty)`
	`1064`	`+ assert(filterExec.size === 1)`
`1065`	`1065`
`1066`	`1066`	`checkAnswer(df, Row(1, 2, 1, 2) :: Nil)`
`1067`	`1067`	`}`