Repository: spark
Updated Branches:
refs/heads/branch-1.5 b8136d7e0 -> 05cbf133d
[SPARK-9649] Fix flaky test MasterSuite - randomize ports
```
Error Message
Failed to bind to: /127.0.0.1:7093: Service 'sparkMaster' failed after 16
retries!
Stacktrace
java.net.BindException: Failed to bind to: /127.0.0.1:7093: Service
'sparkMaster' failed after 16 retries!
at
org.jboss.netty.bootstrap.ServerBootstrap.bind(ServerBootstrap.java:272)
at
akka.remote.transport.netty.NettyTransport$$anonfun$listen$1.apply(NettyTransport.scala:393)
at
akka.remote.transport.netty.NettyTransport$$anonfun$listen$1.apply(NettyTransport.scala:389)
at scala.util.Success$$anonfun$map$1.apply(Try.scala:206)
at scala.util.Try$.apply(Try.scala:161)
```
Author: Andrew Or <[email protected]>
Closes #7968 from andrewor14/fix-master-flaky-test and squashes the following
commits:
fcc42ef [Andrew Or] Randomize port
(cherry picked from commit 5f0fb6466f5e3607f7fca9b2371a73b3deef3fdf)
Signed-off-by: Yin Huai <[email protected]>
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/05cbf133
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/05cbf133
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/05cbf133
Branch: refs/heads/branch-1.5
Commit: 05cbf133d8d12904532353118a7de42fd0a7f155
Parents: b8136d7
Author: Andrew Or <[email protected]>
Authored: Wed Aug 5 14:12:22 2015 -0700
Committer: Yin Huai <[email protected]>
Committed: Wed Aug 5 14:12:31 2015 -0700
----------------------------------------------------------------------
.../scala/org/apache/spark/deploy/master/MasterSuite.scala | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/05cbf133/core/src/test/scala/org/apache/spark/deploy/master/MasterSuite.scala
----------------------------------------------------------------------
diff --git
a/core/src/test/scala/org/apache/spark/deploy/master/MasterSuite.scala
b/core/src/test/scala/org/apache/spark/deploy/master/MasterSuite.scala
index 30780a0..ae0e037 100644
--- a/core/src/test/scala/org/apache/spark/deploy/master/MasterSuite.scala
+++ b/core/src/test/scala/org/apache/spark/deploy/master/MasterSuite.scala
@@ -93,8 +93,8 @@ class MasterSuite extends SparkFunSuite with Matchers with
Eventually with Priva
publicAddress = ""
)
- val (rpcEnv, uiPort, restPort) =
- Master.startRpcEnvAndEndpoint("127.0.0.1", 7077, 8080, conf)
+ val (rpcEnv, _, _) =
+ Master.startRpcEnvAndEndpoint("127.0.0.1", 0, 0, conf)
try {
rpcEnv.setupEndpointRef(Master.SYSTEM_NAME, rpcEnv.address,
Master.ENDPOINT_NAME)
@@ -343,8 +343,8 @@ class MasterSuite extends SparkFunSuite with Matchers with
Eventually with Priva
private def makeMaster(conf: SparkConf = new SparkConf): Master = {
val securityMgr = new SecurityManager(conf)
- val rpcEnv = RpcEnv.create(Master.SYSTEM_NAME, "localhost", 7077, conf,
securityMgr)
- val master = new Master(rpcEnv, rpcEnv.address, 8080, securityMgr, conf)
+ val rpcEnv = RpcEnv.create(Master.SYSTEM_NAME, "localhost", 0, conf,
securityMgr)
+ val master = new Master(rpcEnv, rpcEnv.address, 0, securityMgr, conf)
master
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
