You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@livy.apache.org by va...@apache.org on 2018/11/28 21:49:05 UTC
incubator-livy git commit: [LIVY-537] Add hiveconf for setting the
num of executors in thrift sessions
Repository: incubator-livy
Updated Branches:
refs/heads/master 8504c641e -> ae2228f56
[LIVY-537] Add hiveconf for setting the num of executors in thrift sessions
## What changes were proposed in this pull request?
We missed to add a parameter to set the number of executors when creating a session through the thrift API. See https://issues.apache.org/jira/browse/LIVY-537.
## How was this patch tested?
Manual tests.
Author: Marco Gaido <mg...@hortonworks.com>
Closes #130 from mgaido91/LIVY-537.
Project: http://git-wip-us.apache.org/repos/asf/incubator-livy/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-livy/commit/ae2228f5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-livy/tree/ae2228f5
Diff: http://git-wip-us.apache.org/repos/asf/incubator-livy/diff/ae2228f5
Branch: refs/heads/master
Commit: ae2228f568f97865eb502a2cb568d431eeda47c0
Parents: 8504c64
Author: Marco Gaido <mg...@hortonworks.com>
Authored: Wed Nov 28 13:48:58 2018 -0800
Committer: Marcelo Vanzin <va...@cloudera.com>
Committed: Wed Nov 28 13:48:58 2018 -0800
----------------------------------------------------------------------
.../org/apache/livy/thriftserver/LivyThriftSessionManager.scala | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-livy/blob/ae2228f5/thriftserver/server/src/main/scala/org/apache/livy/thriftserver/LivyThriftSessionManager.scala
----------------------------------------------------------------------
diff --git a/thriftserver/server/src/main/scala/org/apache/livy/thriftserver/LivyThriftSessionManager.scala b/thriftserver/server/src/main/scala/org/apache/livy/thriftserver/LivyThriftSessionManager.scala
index 7c7b265..2dca1d4 100644
--- a/thriftserver/server/src/main/scala/org/apache/livy/thriftserver/LivyThriftSessionManager.scala
+++ b/thriftserver/server/src/main/scala/org/apache/livy/thriftserver/LivyThriftSessionManager.scala
@@ -594,6 +594,8 @@ object LivyThriftSessionManager extends Logging {
createInteractiveRequest.executorMemory = Some(value)
case "set:hiveconf:livy.session.executorCores" =>
createInteractiveRequest.executorCores = convertConfValueToInt(key, value)
+ case "set:hiveconf:livy.session.numExecutors" =>
+ createInteractiveRequest.numExecutors = convertConfValueToInt(key, value)
case "set:hiveconf:livy.session.queue" =>
createInteractiveRequest.queue = Some(value)
case "set:hiveconf:livy.session.name" =>