Skip to content

Commit

Permalink
[SPARK-32753][SQL][FOLLOWUP] Fix indentation and clean up view in test
Browse files Browse the repository at this point in the history
### What changes were proposed in this pull request?
Fix indentation and clean up view in the test added by apache#29593.

### Why are the changes needed?
Address review comments in apache#29665.

### Does this PR introduce _any_ user-facing change?
No.

### How was this patch tested?
Updated test.

Closes apache#29682 from manuzhang/spark-32753-followup.

Authored-by: manuzhang <owenzhang1990@gmail.com>
Signed-off-by: HyukjinKwon <gurwls223@apache.org>
  • Loading branch information
manuzhang authored and rshkv committed Feb 17, 2021
1 parent 1efe81b commit 8505980
Showing 1 changed file with 10 additions and 10 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -406,16 +406,16 @@ class AdaptiveQueryExecSuite
}

test("SPARK-32753: Only copy tags to node with no tags") {
withSQLConf(
SQLConf.ADAPTIVE_EXECUTION_ENABLED.key -> "true"
) {
spark.range(10).union(spark.range(10)).createOrReplaceTempView("v1")

val (_, adaptivePlan) = runAdaptiveAndVerifyResult(
"SELECT id FROM v1 GROUP BY id DISTRIBUTE BY id")
assert(collect(adaptivePlan) {
case s: ShuffleExchangeExec => s
}.length == 1)
withSQLConf(SQLConf.ADAPTIVE_EXECUTION_ENABLED.key -> "true") {
withTempView("v1") {
spark.range(10).union(spark.range(10)).createOrReplaceTempView("v1")

val (_, adaptivePlan) = runAdaptiveAndVerifyResult(
"SELECT id FROM v1 GROUP BY id DISTRIBUTE BY id")
assert(collect(adaptivePlan) {
case s: ShuffleExchangeExec => s
}.length == 1)
}
}
}
}

0 comments on commit 8505980

Please sign in to comment.