Skip to content

Commit 91b182f

Browse files
committed
modify joinSuite.scala
1 parent ed8cdb5 commit 91b182f

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

sql/core/src/test/scala/org/apache/spark/sql/JoinSuite.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -75,11 +75,11 @@ class JoinSuite extends QueryTest with BeforeAndAfterEach {
7575
("SELECT * FROM testData JOIN testData2 ON key = a", classOf[ShuffledHashJoin]),
7676
("SELECT * FROM testData JOIN testData2 ON key = a and key = 2", classOf[ShuffledHashJoin]),
7777
("SELECT * FROM testData JOIN testData2 ON key = a where key = 2", classOf[ShuffledHashJoin]),
78-
("SELECT * FROM testData LEFT JOIN testData2 ON key = a", classOf[HashOuterJoin]),
78+
("SELECT * FROM testData LEFT JOIN testData2 ON key = a", classOf[ShuffledHashJoin]),
7979
("SELECT * FROM testData RIGHT JOIN testData2 ON key = a where key = 2",
80-
classOf[HashOuterJoin]),
80+
classOf[ShuffledHashJoin]),
8181
("SELECT * FROM testData right join testData2 ON key = a and key = 2",
82-
classOf[HashOuterJoin]),
82+
classOf[ShuffledHashJoin]),
8383
("SELECT * FROM testData full outer join testData2 ON key = a", classOf[HashOuterJoin])
8484
// TODO add BroadcastNestedLoopJoin
8585
).foreach { case (query, joinClass) => assertJoin(query, joinClass) }

0 commit comments

Comments
 (0)