diff options
| author | Thomas Graves <tgraves@apache.org> | 2014-04-17 16:36:37 -0500 |
|---|---|---|
| committer | Thomas Graves <tgraves@apache.org> | 2014-04-17 16:36:50 -0500 |
| commit | 6195fb8db9f194856df7f5c02f5023596d0c3253 (patch) | |
| tree | d57d951f0831f3d3b659ab36c9b180005f002ba9 /yarn/stable | |
| parent | a83a794f1accc616cfccde78af44c5cbf066c647 (diff) | |
| download | spark-6195fb8db9f194856df7f5c02f5023596d0c3253.tar.gz spark-6195fb8db9f194856df7f5c02f5023596d0c3253.tar.bz2 spark-6195fb8db9f194856df7f5c02f5023596d0c3253.zip | |
SPARK-1408 Modify Spark on Yarn to point to the history server when app ...
...finishes
Note this is dependent on https://github.com/apache/spark/pull/204 to have a working history server, but there are no code dependencies.
This also fixes SPARK-1288 yarn stable finishApplicationMaster incomplete. Since I was in there I made the diagnostic message be passed properly.
Author: Thomas Graves <tgraves@apache.org>
Closes #362 from tgravescs/SPARK-1408 and squashes the following commits:
ec89705 [Thomas Graves] Fix typo.
446122d [Thomas Graves] Make config yarn specific
f5d5373 [Thomas Graves] SPARK-1408 Modify Spark on Yarn to point to the history server when app finishes
(cherry picked from commit 0058b5d2c74147d24b127a5432f89ebc7050dc18)
Signed-off-by: Thomas Graves <tgraves@apache.org>
Diffstat (limited to 'yarn/stable')
| -rw-r--r-- | yarn/stable/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/yarn/stable/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala b/yarn/stable/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala index 581cfe43b6..b225be6a79 100644 --- a/yarn/stable/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala +++ b/yarn/stable/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala @@ -347,8 +347,8 @@ class ApplicationMaster(args: ApplicationMasterArguments, conf: Configuration, logInfo("finishApplicationMaster with " + status) if (registered) { - // Set tracking URL to empty since we don't have a history server. - amClient.unregisterApplicationMaster(status, "" /* appMessage */ , "" /* appTrackingUrl */) + val trackingUrl = sparkConf.get("spark.yarn.historyServer.address", "") + amClient.unregisterApplicationMaster(status, diagnostics, trackingUrl) } } } |