You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by tg...@apache.org on 2014/01/10 22:34:54 UTC
[2/4] git commit: add application type
add application type
Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/5fccd705
Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/5fccd705
Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/5fccd705
Branch: refs/heads/master
Commit: 5fccd7051d40ca022f4d3bab661c8f53a748aa8d
Parents: c617083
Author: Thomas Graves <tg...@apache.org>
Authored: Thu Jan 9 10:32:35 2014 -0600
Committer: Thomas Graves <tg...@apache.org>
Committed: Thu Jan 9 10:32:35 2014 -0600
----------------------------------------------------------------------
.../stable/src/main/scala/org/apache/spark/deploy/yarn/Client.scala | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/5fccd705/yarn/stable/src/main/scala/org/apache/spark/deploy/yarn/Client.scala
----------------------------------------------------------------------
diff --git a/yarn/stable/src/main/scala/org/apache/spark/deploy/yarn/Client.scala b/yarn/stable/src/main/scala/org/apache/spark/deploy/yarn/Client.scala
index be323d7..952e963 100644
--- a/yarn/stable/src/main/scala/org/apache/spark/deploy/yarn/Client.scala
+++ b/yarn/stable/src/main/scala/org/apache/spark/deploy/yarn/Client.scala
@@ -99,6 +99,7 @@ class Client(args: ClientArguments, conf: Configuration, sparkConf: SparkConf)
appContext.setApplicationName(args.appName)
appContext.setQueue(args.amQueue)
appContext.setAMContainerSpec(amContainer)
+ appContext.setApplicationType("SPARK")
// Memory for the ApplicationMaster.
val memoryResource = Records.newRecord(classOf[Resource]).asInstanceOf[Resource]