Skip to content

Commit 446122d

Browse files
committed
Make config yarn specific
1 parent f5d5373 commit 446122d

File tree

4 files changed

+3
-9
lines changed

4 files changed

+3
-9
lines changed

docs/configuration.md

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -627,13 +627,6 @@ Apart from these, the following properties are also available, and may be useful
627627
Number of cores to allocate for each task.
628628
</td>
629629
</tr>
630-
<tr>
631-
<td>spark.historyserver.address</td>
632-
<td>localhost:18080</td>
633-
<td>
634-
The URL of the Spark history server. The history server is optional.
635-
</td>
636-
</tr>
637630
</table>
638631

639632
## Viewing Spark Properties

docs/running-on-yarn.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -42,6 +42,7 @@ System Properties:
4242
* `spark.yarn.preserve.staging.files`, set to true to preserve the staged files(spark jar, app jar, distributed cache files) at the end of the job rather then delete them.
4343
* `spark.yarn.scheduler.heartbeat.interval-ms`, the interval in ms in which the Spark application master heartbeats into the YARN ResourceManager. Default is 5 seconds.
4444
* `spark.yarn.max.executor.failures`, the maximum number of executor failures before failing the application. Default is the number of executors requested times 2 with minimum of 3.
45+
* `spark.yarn.historyServer.address`, the address of the Spark history server (i.e. host.com:18080). The address should not contain a scheme (http://). Defaults to not being set since the history server is an optional service. This address is given to the Yarn ResourceManager when the Spark application finishes to link the application from the ResourceManaer UI to the Spark history server UI.
4546

4647
# Launching Spark on YARN
4748

yarn/alpha/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -366,7 +366,7 @@ class ApplicationMaster(args: ApplicationMasterArguments, conf: Configuration,
366366
finishReq.setAppAttemptId(appAttemptId)
367367
finishReq.setFinishApplicationStatus(status)
368368
finishReq.setDiagnostics(diagnostics)
369-
finishReq.setTrackingUrl(sparkConf.get("spark.historyserver.address", ""))
369+
finishReq.setTrackingUrl(sparkConf.get("spark.yarn.historyServer.address", ""))
370370
resourceManager.finishApplicationMaster(finishReq)
371371
}
372372
}

yarn/stable/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -347,7 +347,7 @@ class ApplicationMaster(args: ApplicationMasterArguments, conf: Configuration,
347347

348348
logInfo("finishApplicationMaster with " + status)
349349
if (registered) {
350-
val trackingUrl = sparkConf.get("spark.historyserver.address", "")
350+
val trackingUrl = sparkConf.get("spark.yarn.historyServer.address", "")
351351
amClient.unregisterApplicationMaster(status, diagnostics, trackingUrl)
352352
}
353353
}

0 commit comments

Comments
 (0)