spark-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From joshro...@apache.org
Subject spark git commit: [SPARK-4837] NettyBlockTransferService should use spark.blockManager.port config
Date Fri, 19 Dec 2014 00:43:40 GMT
Repository: spark
Updated Branches:
  refs/heads/master f9f58b9a0 -> 105293a7d


[SPARK-4837] NettyBlockTransferService should use spark.blockManager.port config

This is used in NioBlockTransferService here:
https://github.com/apache/spark/blob/master/core/src/main/scala/org/apache/spark/network/nio/NioBlockTransferService.scala#L66

Author: Aaron Davidson <aaron@databricks.com>

Closes #3688 from aarondav/SPARK-4837 and squashes the following commits:

ebd2007 [Aaron Davidson] [SPARK-4837] NettyBlockTransferService should use spark.blockManager.port
config


Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/105293a7
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/105293a7
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/105293a7

Branch: refs/heads/master
Commit: 105293a7d06b26e7b179a0447eb802074ee9c218
Parents: f9f58b9
Author: Aaron Davidson <aaron@databricks.com>
Authored: Thu Dec 18 16:43:16 2014 -0800
Committer: Josh Rosen <joshrosen@databricks.com>
Committed: Thu Dec 18 16:43:16 2014 -0800

----------------------------------------------------------------------
 .../org/apache/spark/network/netty/NettyBlockTransferService.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/spark/blob/105293a7/core/src/main/scala/org/apache/spark/network/netty/NettyBlockTransferService.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/org/apache/spark/network/netty/NettyBlockTransferService.scala
b/core/src/main/scala/org/apache/spark/network/netty/NettyBlockTransferService.scala
index 0027cbb..3f0950d 100644
--- a/core/src/main/scala/org/apache/spark/network/netty/NettyBlockTransferService.scala
+++ b/core/src/main/scala/org/apache/spark/network/netty/NettyBlockTransferService.scala
@@ -60,7 +60,7 @@ class NettyBlockTransferService(conf: SparkConf, securityManager: SecurityManage
     }
     transportContext = new TransportContext(transportConf, rpcHandler)
     clientFactory = transportContext.createClientFactory(bootstrap.toList)
-    server = transportContext.createServer()
+    server = transportContext.createServer(conf.getInt("spark.blockManager.port", 0))
     appId = conf.getAppId
     logInfo("Server created on " + server.getPort)
   }


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org


Mime
View raw message