You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by rx...@apache.org on 2016/05/20 05:23:31 UTC
spark git commit: [SPARK-14261][SQL] Memory leak in Spark Thrift
Server
Repository: spark
Updated Branches:
refs/heads/master 3ba34d435 -> e384c7fbb
[SPARK-14261][SQL] Memory leak in Spark Thrift Server
Fixed memory leak (HiveConf in the CommandProcessorFactory)
Author: Oleg Danilov <ol...@wandisco.com>
Closes #12932 from dosoft/SPARK-14261.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/e384c7fb
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/e384c7fb
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/e384c7fb
Branch: refs/heads/master
Commit: e384c7fbb94cef3c18e8fa8d06159b76b88b5167
Parents: 3ba34d4
Author: Oleg Danilov <ol...@wandisco.com>
Authored: Thu May 19 22:23:28 2016 -0700
Committer: Reynold Xin <rx...@databricks.com>
Committed: Thu May 19 22:23:28 2016 -0700
----------------------------------------------------------------------
.../scala/org/apache/spark/sql/hive/client/HiveClientImpl.scala | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/e384c7fb/sql/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveClientImpl.scala
----------------------------------------------------------------------
diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveClientImpl.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveClientImpl.scala
index 0f0c1b0..71d5c99 100644
--- a/sql/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveClientImpl.scala
+++ b/sql/hive/src/main/scala/org/apache/spark/sql/hive/client/HiveClientImpl.scala
@@ -545,12 +545,14 @@ private[hive] class HiveClientImpl(
// Throw an exception if there is an error in query processing.
if (response.getResponseCode != 0) {
driver.close()
+ CommandProcessorFactory.clean(conf)
throw new QueryExecutionException(response.getErrorMessage)
}
driver.setMaxRows(maxRows)
val results = shim.getDriverResults(driver)
driver.close()
+ CommandProcessorFactory.clean(conf)
results
case _ =>
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org