Skip to content

Commit 0f5142c

Browse files
author
Marcelo Vanzin
committed
Review feedback.
1 parent 41f8c8a commit 0f5142c

File tree

4 files changed

+6
-5
lines changed

4 files changed

+6
-5
lines changed

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -190,7 +190,8 @@ private[spark] class ApplicationMaster(args: ApplicationMasterArguments,
190190
conf = sparkConf, securityManager = securityMgr)._1
191191
actor = waitForSparkDriver()
192192
addAmIpFilter()
193-
registerAM(sparkConf.get("spark.driver.appUIAddress", ""), "")
193+
registerAM(sparkConf.get("spark.driver.appUIAddress", ""),
194+
sparkConf.get("spark.driver.appUIHistoryAddress", ""))
194195

195196
// In client mode the actor will stop the reporter thread.
196197
reporterThread.join()

yarn/common/src/main/scala/org/apache/spark/deploy/yarn/YarnRMClient.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -50,8 +50,8 @@ trait YarnRMClient {
5050
/**
5151
* Shuts down the AM. Guaranteed to only be called once.
5252
*
53-
* @param registered Whether the AM was successfully registered with the RM.
5453
* @param status The final status of the AM.
54+
* @param diagnostics Diagnostics message to include in the final status.
5555
*/
5656
def shutdown(status: FinalApplicationStatus, diagnostics: String = ""): Unit
5757

yarn/common/src/main/scala/org/apache/spark/deploy/yarn/YarnSparkHadoopUtil.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -193,14 +193,14 @@ object YarnSparkHadoopUtil {
193193
}
194194
}
195195

196-
def lookupRack(conf: Configuration, host: String): String = {
196+
private[spark] def lookupRack(conf: Configuration, host: String): String = {
197197
if (!hostToRack.contains(host)) {
198198
populateRackInfo(conf, host)
199199
}
200200
hostToRack.get(host)
201201
}
202202

203-
def populateRackInfo(conf: Configuration, hostname: String) {
203+
private[spark] def populateRackInfo(conf: Configuration, hostname: String) {
204204
Utils.checkHost(hostname)
205205

206206
if (!hostToRack.containsKey(hostname)) {

yarn/common/src/main/scala/org/apache/spark/scheduler/cluster/YarnClientSchedulerBackend.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@ package org.apache.spark.scheduler.cluster
1919

2020
import org.apache.hadoop.yarn.api.records.{ApplicationId, YarnApplicationState}
2121
import org.apache.spark.{SparkException, Logging, SparkContext}
22-
import org.apache.spark.deploy.yarn.{ApplicationMaster, Client, ClientArguments, YarnSparkHadoopUtil}
22+
import org.apache.spark.deploy.yarn.{Client, ClientArguments, YarnSparkHadoopUtil}
2323
import org.apache.spark.scheduler.TaskSchedulerImpl
2424

2525
import scala.collection.mutable.ArrayBuffer

0 commit comments

Comments
 (0)