aboutsummaryrefslogtreecommitdiff
path: root/yarn/stable
diff options
context:
space:
mode:
authorThomas Graves <tgraves@apache.org>2014-01-09 10:32:35 -0600
committerThomas Graves <tgraves@apache.org>2014-01-09 10:32:35 -0600
commit5fccd7051d40ca022f4d3bab661c8f53a748aa8d (patch)
tree75a205f6f1f0deedf56d2c424ea8af7c0b096e3d /yarn/stable
parentc617083e478e3cfbddc4232060aa7b7a0c5812d4 (diff)
downloadspark-5fccd7051d40ca022f4d3bab661c8f53a748aa8d.tar.gz
spark-5fccd7051d40ca022f4d3bab661c8f53a748aa8d.tar.bz2
spark-5fccd7051d40ca022f4d3bab661c8f53a748aa8d.zip
add application type
Diffstat (limited to 'yarn/stable')
-rw-r--r--yarn/stable/src/main/scala/org/apache/spark/deploy/yarn/Client.scala1
1 files changed, 1 insertions, 0 deletions
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 be323d7783..952e963389 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]