@@ -113,14 +113,17 @@ class JoinSuite extends QueryTest with BeforeAndAfterEach {
113113 Seq (
114114 (" SELECT * FROM testData join testData2 ON key = a" , classOf [BroadcastHashJoin ]),
115115 (" 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 ])
117118 ).foreach { case (query, joinClass) => assertJoin(query, joinClass) }
118119 try {
119120 conf.setConf(" spark.sql.planner.sortMergeJoin" , " true" )
120121 Seq (
121122 (" 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 ])
124127 ).foreach { case (query, joinClass) => assertJoin(query, joinClass) }
125128 } finally {
126129 conf.setConf(" spark.sql.planner.sortMergeJoin" , SORTMERGEJOIN_ENABLED .toString)
0 commit comments