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 @@ -278,16 +278,16 @@ class ExplainSuite extends ExplainSuiteHelper with DisableAdaptiveExecutionSuite
278
278
}
279
279
280
280
test(" explain formatted - check presence of subquery in case of AQE" ) {
281
- withTable(" df1" , " df2 " ) {
281
+ withTable(" df1" ) {
282
282
withSQLConf(SQLConf .ADAPTIVE_EXECUTION_ENABLED .key -> " true" ) {
283
283
withTable(" df1" ) {
284
- spark.range(1 )
284
+ spark.range(1 , 100 )
285
285
.write
286
286
.format(" parquet" )
287
287
.mode(" overwrite" )
288
288
.saveAsTable(" df1" )
289
289
290
- val sqlText = " EXPLAIN FORMATTED SELECT (SELECT id FROM df1) as v"
290
+ val sqlText = " EXPLAIN FORMATTED SELECT (SELECT min(id) FROM df1) as v"
291
291
val expected_pattern1 =
292
292
" Subquery:1 Hosting operator id = 2 Hosting Expression = Subquery subquery#x"
293
293
You can’t perform that action at this time.
0 commit comments