[SPARK-6653][yarn] New configuration property to specify port for sparkYarnAM actor system

shekhar.bansal · shekhar.bansal · commit 803e93e079dd · 2015-04-27T16:53:46.000+05:30
diff --git a/yarn/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala b/yarn/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala
@@ -274,7 +274,8 @@ private[spark] class ApplicationMaster(
   }
 
   private def runExecutorLauncher(securityMgr: SecurityManager): Unit = {
-    rpcEnv = RpcEnv.create("sparkYarnAM", Utils.localHostName, 0, sparkConf, securityMgr)
+    val port = sparkConf.getInt("spark.yarn.am.port", 0)
+    rpcEnv = RpcEnv.create("sparkYarnAM", Utils.localHostName, port, sparkConf, securityMgr)
     waitForSparkDriver()
     addAmIpFilter()
     registerAM(sparkConf.get("spark.driver.appUIAddress", ""), securityMgr)

Original file line number	Diff line number	Diff line change
`@@ -274,7 +274,8 @@ private[spark] class ApplicationMaster(`
`274`	`274`	`}`
`275`	`275`
`276`	`276`	`private def runExecutorLauncher(securityMgr: SecurityManager): Unit = {`
`277`		`- rpcEnv = RpcEnv.create("sparkYarnAM", Utils.localHostName, 0, sparkConf, securityMgr)`
	`277`	`+ val port = sparkConf.getInt("spark.yarn.am.port", 0)`
	`278`	`+ rpcEnv = RpcEnv.create("sparkYarnAM", Utils.localHostName, port, sparkConf, securityMgr)`
`278`	`279`	`waitForSparkDriver()`
`279`	`280`	`addAmIpFilter()`
`280`	`281`	`registerAM(sparkConf.get("spark.driver.appUIAddress", ""), securityMgr)`