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 <mga...@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 <mga...@hortonworks.com>
Authored: Wed Nov 28 13:48:58 2018 -0800
Committer: Marcelo Vanzin <van...@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" =>

Reply via email to