You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@livy.apache.org by js...@apache.org on 2017/06/27 06:39:18 UTC
[37/50] [abbrv] incubator-livy git commit: LIVY-340. Add YARN queue
support to interactive sessions. (#314)
LIVY-340. Add YARN queue support to interactive sessions. (#314)
Project: http://git-wip-us.apache.org/repos/asf/incubator-livy/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-livy/commit/7212e3f3
Tree: http://git-wip-us.apache.org/repos/asf/incubator-livy/tree/7212e3f3
Diff: http://git-wip-us.apache.org/repos/asf/incubator-livy/diff/7212e3f3
Branch: refs/heads/master
Commit: 7212e3f3bbed07ab8ea372cd7a56ee1cd2b56693
Parents: 511a05f
Author: Praveen Kanamarlapudi <kp...@outlook.com>
Authored: Tue Apr 18 13:02:23 2017 -0700
Committer: Alex Man <al...@users.noreply.github.com>
Committed: Tue Apr 18 13:02:23 2017 -0700
----------------------------------------------------------------------
.../com/cloudera/livy/server/interactive/InteractiveSession.scala | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-livy/blob/7212e3f3/server/src/main/scala/com/cloudera/livy/server/interactive/InteractiveSession.scala
----------------------------------------------------------------------
diff --git a/server/src/main/scala/com/cloudera/livy/server/interactive/InteractiveSession.scala b/server/src/main/scala/com/cloudera/livy/server/interactive/InteractiveSession.scala
index b53dea7..6d10c57 100644
--- a/server/src/main/scala/com/cloudera/livy/server/interactive/InteractiveSession.scala
+++ b/server/src/main/scala/com/cloudera/livy/server/interactive/InteractiveSession.scala
@@ -88,7 +88,8 @@ object InteractiveSession extends Logging {
SparkLauncher.EXECUTOR_CORES -> request.executorCores.map(_.toString),
SparkLauncher.EXECUTOR_MEMORY -> request.executorMemory.map(_.toString),
"spark.executor.instances" -> request.numExecutors.map(_.toString),
- "spark.app.name" -> request.name.map(_.toString)
+ "spark.app.name" -> request.name.map(_.toString),
+ "spark.yarn.queue" -> request.queue
)
userOpts.foreach { case (key, opt) =>