diff options
Diffstat (limited to 'sql/core/src/test/scala')
| -rw-r--r-- | sql/core/src/test/scala/org/apache/spark/sql/QueryTest.scala | 4 | ||||
| -rw-r--r-- | sql/core/src/test/scala/org/apache/spark/sql/execution/benchmark/TPCDSQueryBenchmark.scala | 1 |
2 files changed, 2 insertions, 3 deletions
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/QueryTest.scala b/sql/core/src/test/scala/org/apache/spark/sql/QueryTest.scala index 304881d4a4..cff9d22d08 100644 --- a/sql/core/src/test/scala/org/apache/spark/sql/QueryTest.scala +++ b/sql/core/src/test/scala/org/apache/spark/sql/QueryTest.scala @@ -292,7 +292,7 @@ abstract class QueryTest extends PlanTest { p.expressions.foreach { _.foreach { case s: SubqueryExpression => - s.query.foreach(collectData) + s.plan.foreach(collectData) case _ => } } @@ -334,7 +334,7 @@ abstract class QueryTest extends PlanTest { case p => p.transformExpressions { case s: SubqueryExpression => - s.withNewPlan(s.query.transformDown(renormalize)) + s.withNewPlan(s.plan.transformDown(renormalize)) } } val normalized2 = jsonBackPlan.transformDown(renormalize) diff --git a/sql/core/src/test/scala/org/apache/spark/sql/execution/benchmark/TPCDSQueryBenchmark.scala b/sql/core/src/test/scala/org/apache/spark/sql/execution/benchmark/TPCDSQueryBenchmark.scala index 957a1d6426..3988d9750b 100644 --- a/sql/core/src/test/scala/org/apache/spark/sql/execution/benchmark/TPCDSQueryBenchmark.scala +++ b/sql/core/src/test/scala/org/apache/spark/sql/execution/benchmark/TPCDSQueryBenchmark.scala @@ -26,7 +26,6 @@ import org.apache.spark.sql.catalyst.analysis.UnresolvedRelation import org.apache.spark.sql.catalyst.expressions.SubqueryExpression import org.apache.spark.sql.catalyst.plans.logical.LogicalPlan import org.apache.spark.sql.catalyst.util._ -import org.apache.spark.sql.internal.SQLConf import org.apache.spark.util.Benchmark /** |