Skip to content

Commit e8d8077

Browse files
lianchengpwendell
authored andcommitted
[SPARK-4761][SQL] Enables Kryo by default in Spark SQL Thrift server
Enables Kryo and disables reference tracking by default in Spark SQL Thrift server. Configurations explicitly defined by users in `spark-defaults.conf` are respected (the Thrift server is started by `spark-submit`, which handles configuration properties properly). <!-- Reviewable:start --> [<img src="https://reviewable.io/review_button.png" height=40 alt="Review on Reviewable"/>](https://reviewable.io/reviews/apache/spark/3621) <!-- Reviewable:end --> Author: Cheng Lian <[email protected]> Closes #3621 from liancheng/kryo-by-default and squashes the following commits: 70c2775 [Cheng Lian] Enables Kryo by default in Spark SQL Thrift server (cherry picked from commit 6f61e1f) Signed-off-by: Patrick Wendell <[email protected]>
1 parent d12ea49 commit e8d8077

File tree

1 file changed

+12
-2
lines changed
  • sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver

1 file changed

+12
-2
lines changed

sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLEnv.scala

Lines changed: 12 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -32,11 +32,21 @@ private[hive] object SparkSQLEnv extends Logging {
3232

3333
def init() {
3434
if (hiveContext == null) {
35-
val sparkConf = new SparkConf()
35+
val sparkConf = new SparkConf(loadDefaults = true)
36+
val maybeSerializer = sparkConf.getOption("spark.serializer")
37+
val maybeKryoReferenceTracking = sparkConf.getOption("spark.kryo.referenceTracking")
38+
39+
sparkConf
3640
.setAppName(s"SparkSQL::${java.net.InetAddress.getLocalHost.getHostName}")
3741
.set("spark.sql.hive.version", HiveShim.version)
38-
sparkContext = new SparkContext(sparkConf)
42+
.set(
43+
"spark.serializer",
44+
maybeSerializer.getOrElse("org.apache.spark.serializer.KryoSerializer"))
45+
.set(
46+
"spark.kryo.referenceTracking",
47+
maybeKryoReferenceTracking.getOrElse("false"))
3948

49+
sparkContext = new SparkContext(sparkConf)
4050
sparkContext.addSparkListener(new StatsReportListener())
4151
hiveContext = new HiveContext(sparkContext)
4252

0 commit comments

Comments
 (0)