File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
sql/core/src/test/scala/org/apache/spark/sql/execution/adaptive Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -1611,13 +1611,13 @@ class AdaptiveQueryExecSuite
16111611 withTempView(" t1" , " t2" ) {
16121612 def checkJoinStrategy (shouldBroadcast : Boolean ): Unit = {
16131613 withSQLConf(SQLConf .AUTO_BROADCASTJOIN_THRESHOLD .key -> " -1" ) {
1614- val (origin1, adaptive1 ) = runAdaptiveAndVerifyResult(
1614+ val (origin, adaptive ) = runAdaptiveAndVerifyResult(
16151615 " SELECT t1.c1, t2.c1 FROM t1 JOIN t2 ON t1.c1 = t2.c1" )
1616- assert(findTopLevelSortMergeJoin(origin1 ).size == 1 )
1616+ assert(findTopLevelSortMergeJoin(origin ).size == 1 )
16171617 if (shouldBroadcast) {
1618- assert(findTopLevelBroadcastHashJoin(adaptive1 ).size == 1 )
1618+ assert(findTopLevelBroadcastHashJoin(adaptive ).size == 1 )
16191619 } else {
1620- assert(findTopLevelSortMergeJoin(adaptive1 ).size == 1 )
1620+ assert(findTopLevelSortMergeJoin(adaptive ).size == 1 )
16211621 }
16221622 }
16231623 }
You can’t perform that action at this time.
0 commit comments