From b80d2fd8e9b27a4d49561d31f100ffbb75393685 Mon Sep 17 00:00:00 2001 From: Andrew Ash Date: Mon, 16 Jun 2014 23:40:32 -0700 Subject: [PATCH] Make Spark's block manager port configurable spark.blockManager.port --- .../src/main/scala/org/apache/spark/storage/BlockManager.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/core/src/main/scala/org/apache/spark/storage/BlockManager.scala b/core/src/main/scala/org/apache/spark/storage/BlockManager.scala index 0db0a5bc7341b..ae55a0ace5b4f 100644 --- a/core/src/main/scala/org/apache/spark/storage/BlockManager.scala +++ b/core/src/main/scala/org/apache/spark/storage/BlockManager.scala @@ -63,7 +63,8 @@ private[spark] class BlockManager( val shuffleBlockManager = new ShuffleBlockManager(this) val diskBlockManager = new DiskBlockManager(shuffleBlockManager, conf.get("spark.local.dir", System.getProperty("java.io.tmpdir"))) - val connectionManager = new ConnectionManager(0, conf, securityManager) + val connectionManager = new ConnectionManager(conf.getInt("spark.blockManager.port", 0), conf, + securityManager) implicit val futureExecContext = connectionManager.futureExecContext