@@ -113,14 +113,17 @@ class JoinSuite extends QueryTest with BeforeAndAfterEach {
113
113
Seq (
114
114
(" SELECT * FROM testData join testData2 ON key = a" , classOf [BroadcastHashJoin ]),
115
115
(" SELECT * FROM testData join testData2 ON key = a and key = 2" , classOf [BroadcastHashJoin ]),
116
- (" SELECT * FROM testData join testData2 ON key = a where key = 2" , classOf [BroadcastHashJoin ])
116
+ (" SELECT * FROM testData join testData2 ON key = a where key = 2" ,
117
+ classOf [BroadcastHashJoin ])
117
118
).foreach { case (query, joinClass) => assertJoin(query, joinClass) }
118
119
try {
119
120
conf.setConf(" spark.sql.planner.sortMergeJoin" , " true" )
120
121
Seq (
121
122
(" SELECT * FROM testData join testData2 ON key = a" , classOf [BroadcastHashJoin ]),
122
- (" SELECT * FROM testData join testData2 ON key = a and key = 2" , classOf [BroadcastHashJoin ]),
123
- (" SELECT * FROM testData join testData2 ON key = a where key = 2" , classOf [BroadcastHashJoin ])
123
+ (" SELECT * FROM testData join testData2 ON key = a and key = 2" ,
124
+ classOf [BroadcastHashJoin ]),
125
+ (" SELECT * FROM testData join testData2 ON key = a where key = 2" ,
126
+ classOf [BroadcastHashJoin ])
124
127
).foreach { case (query, joinClass) => assertJoin(query, joinClass) }
125
128
} finally {
126
129
conf.setConf(" spark.sql.planner.sortMergeJoin" , SORTMERGEJOIN_ENABLED .toString)
0 commit comments