You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@spark.apache.org by "Manoj Samel (JIRA)" <ji...@apache.org> on 2015/04/01 20:11:53 UTC
[jira] [Created] (SPARK-6653) New configuration property to specify
port for sparkYarnAM actor system
Manoj Samel created SPARK-6653:
----------------------------------
Summary: New configuration property to specify port for sparkYarnAM actor system
Key: SPARK-6653
URL: https://issues.apache.org/jira/browse/SPARK-6653
Project: Spark
Issue Type: Improvement
Components: YARN
Affects Versions: 1.3.0
Environment: Spark On Yarn
Reporter: Manoj Samel
In 1.3.0 code line sparkYarnAM actor system is started on random port. See org.apache.spark.deploy.yarn ApplicationMaster.scala:282
actorSystem = AkkaUtils.createActorSystem("sparkYarnAM", Utils.localHostName, 0, conf = sparkConf, securityManager = securityMgr)._1
This may be issue when ports between Spark client and the Yarn cluster are limited by firewall and not all ports are open between client and Yarn cluster.
Proposal is to introduce new property spark.am.actor.port and change code to
val port = sparkConf.getInt("spark.am.actor.port", 0)
actorSystem = AkkaUtils.createActorSystem("sparkYarnAM", Utils.localHostName, port,
conf = sparkConf, securityManager = securityMgr)._1
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@spark.apache.org
For additional commands, e-mail: issues-help@spark.apache.org