[SPARK-22793][SQL]Memory leak in Spark Thrift Server

zuotingbing · zuotingbing · commit 2b1e166f4f43 · 2017-12-20T15:52:21.000+08:00
diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveSessionStateBuilder.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveSessionStateBuilder.scala
@@ -42,7 +42,7 @@ class HiveSessionStateBuilder(session: SparkSession, parentState: Option[Session
    * Create a Hive aware resource loader.
    */
   override protected lazy val resourceLoader: HiveSessionResourceLoader = {
-    val client: HiveClient = externalCatalog.client.newSession()
+    val client: HiveClient = externalCatalog.client
     new HiveSessionResourceLoader(session, client)
   }
 

Original file line number	Diff line number	Diff line change
`@@ -42,7 +42,7 @@ class HiveSessionStateBuilder(session: SparkSession, parentState: Option[Session`
`42`	`42`	`* Create a Hive aware resource loader.`
`43`	`43`	`*/`
`44`	`44`	`override protected lazy val resourceLoader: HiveSessionResourceLoader = {`
`45`		`- val client: HiveClient = externalCatalog.client.newSession()`
	`45`	`+ val client: HiveClient = externalCatalog.client`
`46`	`46`	`new HiveSessionResourceLoader(session, client)`
`47`	`47`	`}`
`48`	`48`