File tree Expand file tree Collapse file tree 2 files changed +9
-6
lines changed
core/src/test/scala/org/apache/spark/sql
hive/src/test/scala/org/apache/spark/sql/hive Expand file tree Collapse file tree 2 files changed +9
-6
lines changed Original file line number Diff line number Diff line change @@ -389,14 +389,15 @@ class JoinSuite extends QueryTest with BeforeAndAfterEach {
389389 sql(" CACHE TABLE testData" )
390390 val tmp = autoBroadcastJoinThreshold
391391
392- sql( s """ SET ${SQLConf .AUTO_BROADCASTJOIN_THRESHOLD }=1000000000 "" " )
392+ sql(s " SET ${SQLConf .AUTO_BROADCASTJOIN_THRESHOLD }=1000000000 " )
393393 Seq (
394- (" SELECT * FROM testData LEFT SEMI JOIN testData2 ON key = a" , classOf [BroadcastLeftSemiJoinHash ])
394+ (" SELECT * FROM testData LEFT SEMI JOIN testData2 ON key = a" ,
395+ classOf [BroadcastLeftSemiJoinHash ])
395396 ).foreach {
396397 case (query, joinClass) => assertJoin(query, joinClass)
397398 }
398399
399- sql( s """ SET ${SQLConf .AUTO_BROADCASTJOIN_THRESHOLD }=-1 "" " )
400+ sql(s " SET ${SQLConf .AUTO_BROADCASTJOIN_THRESHOLD }=-1 " )
400401
401402 Seq (
402403 (" SELECT * FROM testData LEFT SEMI JOIN testData2 ON key = a" , classOf [LeftSemiJoinHash ])
Original file line number Diff line number Diff line change @@ -204,7 +204,9 @@ class StatisticsSuite extends QueryTest with BeforeAndAfterAll {
204204
205205 // Assert src has a size smaller than the threshold.
206206 val sizes = rdd.queryExecution.analyzed.collect {
207- case r if implicitly[ClassTag [MetastoreRelation ]].runtimeClass.isAssignableFrom(r.getClass) => r.statistics.sizeInBytes
207+ case r if implicitly[ClassTag [MetastoreRelation ]].runtimeClass
208+ .isAssignableFrom(r.getClass) =>
209+ r.statistics.sizeInBytes
208210 }
209211 assert(sizes.size === 2 && sizes(1 ) <= autoBroadcastJoinThreshold
210212 && sizes(0 ) <= autoBroadcastJoinThreshold,
@@ -223,7 +225,7 @@ class StatisticsSuite extends QueryTest with BeforeAndAfterAll {
223225 TestHive .settings.synchronized {
224226 val tmp = autoBroadcastJoinThreshold
225227
226- sql( s """ SET ${SQLConf .AUTO_BROADCASTJOIN_THRESHOLD }=-1 "" " )
228+ sql(s " SET ${SQLConf .AUTO_BROADCASTJOIN_THRESHOLD }=-1 " )
227229 rdd = sql(leftSemiJoinQuery)
228230 bhj = rdd.queryExecution.sparkPlan.collect {
229231 case j : BroadcastLeftSemiJoinHash => j
@@ -236,7 +238,7 @@ class StatisticsSuite extends QueryTest with BeforeAndAfterAll {
236238 assert(shj.size === 1 ,
237239 " LeftSemiJoinHash should be planned when BroadcastHashJoin is turned off" )
238240
239- sql( s """ SET ${SQLConf .AUTO_BROADCASTJOIN_THRESHOLD }= $tmp"" " )
241+ sql(s " SET ${SQLConf .AUTO_BROADCASTJOIN_THRESHOLD }= $tmp" )
240242 }
241243
242244 }
You can’t perform that action at this time.
0 commit comments