You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by li...@apache.org on 2018/01/24 18:07:27 UTC
spark git commit: [SPARK-22837][SQL] Session timeout checker does not
work in SessionManager.
Repository: spark
Updated Branches:
refs/heads/master 8c273b416 -> bbb87b350
[SPARK-22837][SQL] Session timeout checker does not work in SessionManager.
## What changes were proposed in this pull request?
Currently we do not call the `super.init(hiveConf)` in `SparkSQLSessionManager.init`. So we do not load the config `HIVE_SERVER2_SESSION_CHECK_INTERVAL HIVE_SERVER2_IDLE_SESSION_TIMEOUT HIVE_SERVER2_IDLE_SESSION_CHECK_OPERATION` , which cause the session timeout checker does not work.
## How was this patch tested?
manual tests
Author: zuotingbing <zu...@zte.com.cn>
Closes #20025 from zuotingbing/SPARK-22837.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/bbb87b35
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/bbb87b35
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/bbb87b35
Branch: refs/heads/master
Commit: bbb87b350d9d0d393db3fb7ca61dcbae538553bb
Parents: 8c273b4
Author: zuotingbing <zu...@zte.com.cn>
Authored: Wed Jan 24 10:07:24 2018 -0800
Committer: gatorsmile <ga...@gmail.com>
Committed: Wed Jan 24 10:07:24 2018 -0800
----------------------------------------------------------------------
.../hive/thriftserver/SparkSQLSessionManager.scala | 16 +---------------
1 file changed, 1 insertion(+), 15 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/bbb87b35/sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLSessionManager.scala
----------------------------------------------------------------------
diff --git a/sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLSessionManager.scala b/sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLSessionManager.scala
index 48c0ebe..2958b77 100644
--- a/sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLSessionManager.scala
+++ b/sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkSQLSessionManager.scala
@@ -40,22 +40,8 @@ private[hive] class SparkSQLSessionManager(hiveServer: HiveServer2, sqlContext:
private lazy val sparkSqlOperationManager = new SparkSQLOperationManager()
override def init(hiveConf: HiveConf) {
- setSuperField(this, "hiveConf", hiveConf)
-
- // Create operation log root directory, if operation logging is enabled
- if (hiveConf.getBoolVar(ConfVars.HIVE_SERVER2_LOGGING_OPERATION_ENABLED)) {
- invoke(classOf[SessionManager], this, "initOperationLogRootDir")
- }
-
- val backgroundPoolSize = hiveConf.getIntVar(ConfVars.HIVE_SERVER2_ASYNC_EXEC_THREADS)
- setSuperField(this, "backgroundOperationPool", Executors.newFixedThreadPool(backgroundPoolSize))
- getAncestorField[Log](this, 3, "LOG").info(
- s"HiveServer2: Async execution pool size $backgroundPoolSize")
-
setSuperField(this, "operationManager", sparkSqlOperationManager)
- addService(sparkSqlOperationManager)
-
- initCompositeService(hiveConf)
+ super.init(hiveConf)
}
override def openSession(
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org