diff options
Diffstat (limited to 'sql/core/src/test/scala/org/apache/spark/sql/execution/joins/InnerJoinSuite.scala')
-rw-r--r-- | sql/core/src/test/scala/org/apache/spark/sql/execution/joins/InnerJoinSuite.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/execution/joins/InnerJoinSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/execution/joins/InnerJoinSuite.scala index 933f32e496..2a4a3690f2 100644 --- a/sql/core/src/test/scala/org/apache/spark/sql/execution/joins/InnerJoinSuite.scala +++ b/sql/core/src/test/scala/org/apache/spark/sql/execution/joins/InnerJoinSuite.scala @@ -189,7 +189,7 @@ class InnerJoinSuite extends SparkPlanTest with SharedSQLContext { test(s"$testName using CartesianProduct") { withSQLConf(SQLConf.SHUFFLE_PARTITIONS.key -> "1") { checkAnswer2(leftRows, rightRows, (left: SparkPlan, right: SparkPlan) => - FilterExec(condition(), CartesianProductExec(left, right)), + CartesianProductExec(left, right, Some(condition())), expectedAnswer.map(Row.fromTuple), sortAnswers = true) } |