aboutsummaryrefslogtreecommitdiff
path: root/sql/hive/src
diff options
context:
space:
mode:
authorDongjoon Hyun <dongjoon@apache.org>2016-07-05 16:47:32 -0700
committerReynold Xin <rxin@databricks.com>2016-07-05 16:47:32 -0700
commit4db63fd2b430b0902ce0e50f526b1c2e2a5c6497 (patch)
tree65f098e0ea1b5b9e563c1e9c0f1ce2ebb470e3ff /sql/hive/src
parent1f0d021308f2201366111f8390015114710d4f9b (diff)
downloadspark-4db63fd2b430b0902ce0e50f526b1c2e2a5c6497.tar.gz
spark-4db63fd2b430b0902ce0e50f526b1c2e2a5c6497.tar.bz2
spark-4db63fd2b430b0902ce0e50f526b1c2e2a5c6497.zip
[SPARK-16383][SQL] Remove `SessionState.executeSql`
## What changes were proposed in this pull request? This PR removes `SessionState.executeSql` in favor of `SparkSession.sql`. We can remove this safely since the visibility `SessionState` is `private[sql]` and `executeSql` is only used in one **ignored** test, `test("Multiple Hive Instances")`. ## How was this patch tested? Pass the Jenkins tests. Author: Dongjoon Hyun <dongjoon@apache.org> Closes #14055 from dongjoon-hyun/SPARK-16383.
Diffstat (limited to 'sql/hive/src')
-rw-r--r--sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/ConcurrentHiveSuite.scala6
1 files changed, 3 insertions, 3 deletions
diff --git a/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/ConcurrentHiveSuite.scala b/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/ConcurrentHiveSuite.scala
index 1583a448ef..07d8c5bacb 100644
--- a/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/ConcurrentHiveSuite.scala
+++ b/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/ConcurrentHiveSuite.scala
@@ -30,9 +30,9 @@ class ConcurrentHiveSuite extends SparkFunSuite with BeforeAndAfterAll {
conf.set("spark.ui.enabled", "false")
val ts =
new TestHiveContext(new SparkContext("local", s"TestSQLContext$i", conf))
- ts.sessionState.executeSql("SHOW TABLES").toRdd.collect()
- ts.sessionState.executeSql("SELECT * FROM src").toRdd.collect()
- ts.sessionState.executeSql("SHOW TABLES").toRdd.collect()
+ ts.sparkSession.sql("SHOW TABLES").collect()
+ ts.sparkSession.sql("SELECT * FROM src").collect()
+ ts.sparkSession.sql("SHOW TABLES").collect()
}
}
}