Repository: spark Updated Branches: refs/heads/master fdb382275 -> d1508dd9b
[SPARK-12386][CORE] Fix NPE when spark.executor.port is set. Author: Marcelo Vanzin <van...@cloudera.com> Closes #10339 from vanzin/SPARK-12386. Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/d1508dd9 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/d1508dd9 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/d1508dd9 Branch: refs/heads/master Commit: d1508dd9b765489913bc948575a69ebab82f217b Parents: fdb3822 Author: Marcelo Vanzin <van...@cloudera.com> Authored: Wed Dec 16 19:47:49 2015 -0800 Committer: Andrew Or <and...@databricks.com> Committed: Wed Dec 16 19:47:49 2015 -0800 ---------------------------------------------------------------------- core/src/main/scala/org/apache/spark/SparkEnv.scala | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/d1508dd9/core/src/main/scala/org/apache/spark/SparkEnv.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/org/apache/spark/SparkEnv.scala b/core/src/main/scala/org/apache/spark/SparkEnv.scala index 84230e3..52acde1 100644 --- a/core/src/main/scala/org/apache/spark/SparkEnv.scala +++ b/core/src/main/scala/org/apache/spark/SparkEnv.scala @@ -256,7 +256,12 @@ object SparkEnv extends Logging { if (rpcEnv.isInstanceOf[AkkaRpcEnv]) { rpcEnv.asInstanceOf[AkkaRpcEnv].actorSystem } else { - val actorSystemPort = if (port == 0) 0 else rpcEnv.address.port + 1 + val actorSystemPort = + if (port == 0 || rpcEnv.address == null) { + port + } else { + rpcEnv.address.port + 1 + } // Create a ActorSystem for legacy codes AkkaUtils.createActorSystem( actorSystemName + "ActorSystem", --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org
