File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
sql/core/src/test/scala/org/apache/spark/sql Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -1555,7 +1555,7 @@ class SubquerySuite extends QueryTest with SharedSparkSession {
1555
1555
"""
1556
1556
SELECT
1557
1557
(SELECT min(a.key) FROM testData AS a JOIN testData AS b ON b.key = a.key),
1558
- (SELECT max(a.key) FROM testData AS a JOIN testData AS b ON b.key = a.key)
1558
+ (SELECT max(a.key) FROM testData AS a JOIN testData2 AS b ON b.a = a.key)
1559
1559
""" .stripMargin)
1560
1560
1561
1561
val plan2 = df2.queryExecution.executedPlan
@@ -1566,8 +1566,8 @@ class SubquerySuite extends QueryTest with SharedSparkSession {
1566
1566
}
1567
1567
1568
1568
if (reuse) {
1569
- assert(exchangeIds2.size == 3 , " Exchange reusing not working correctly" )
1570
- assert(reusedExchangeIds2.size == 3 , " Exchange reusing not working correctly" )
1569
+ assert(exchangeIds2.size == 4 , " Exchange reusing not working correctly" )
1570
+ assert(reusedExchangeIds2.size == 2 , " Exchange reusing not working correctly" )
1571
1571
assert(reusedExchangeIds2.forall(exchangeIds2.contains(_)),
1572
1572
" ReusedExchangeExec should reuse an existing exchange" )
1573
1573
} else {
You can’t perform that action at this time.
0 commit comments