From f34115d59b83163d9542be09eb0c89a87ea89309 Mon Sep 17 00:00:00 2001 From: Andrew Ash Date: Mon, 16 Jun 2014 22:31:52 -0700 Subject: [PATCH] SPARK-1176 Add port configuration for HttpBroadcast Uses spark.broadcast.port --- .../main/scala/org/apache/spark/broadcast/HttpBroadcast.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/core/src/main/scala/org/apache/spark/broadcast/HttpBroadcast.scala b/core/src/main/scala/org/apache/spark/broadcast/HttpBroadcast.scala index 487456467b23b..eaf3b69a7c5a6 100644 --- a/core/src/main/scala/org/apache/spark/broadcast/HttpBroadcast.scala +++ b/core/src/main/scala/org/apache/spark/broadcast/HttpBroadcast.scala @@ -152,7 +152,8 @@ private[broadcast] object HttpBroadcast extends Logging { private def createServer(conf: SparkConf) { broadcastDir = Utils.createTempDir(Utils.getLocalDir(conf)) - server = new HttpServer(broadcastDir, securityManager) + val broadcastListenPort: Int = conf.getInt("spark.broadcast.port", 0) + server = new HttpServer(broadcastDir, securityManager, broadcastListenPort) server.start() serverUri = server.uri logInfo("Broadcast server started at " + serverUri)