diff options
| author | zsxwing <zsxwing@gmail.com> | 2015-04-30 23:44:33 -0700 |
|---|---|---|
| committer | Patrick Wendell <patrick@databricks.com> | 2015-04-30 23:44:33 -0700 |
| commit | 14b32886fa01aef6cc0dfbc263eb6d4c9d2876fa (patch) | |
| tree | 98f93788c347f5d4d0f0c98fcc018ff8e190278d /core | |
| parent | 7cf1eb79b1fa290aa1d867a8a1eaaea86d6b2239 (diff) | |
| download | spark-14b32886fa01aef6cc0dfbc263eb6d4c9d2876fa.tar.gz spark-14b32886fa01aef6cc0dfbc263eb6d4c9d2876fa.tar.bz2 spark-14b32886fa01aef6cc0dfbc263eb6d4c9d2876fa.zip | |
[SPARK-7291] [CORE] Fix a flaky test in AkkaRpcEnvSuite
Read the port from RpcEnv to check the result so that it will success even if port conflicts
Author: zsxwing <zsxwing@gmail.com>
Closes #5822 from zsxwing/SPARK-7291 and squashes the following commits:
e521b84 [zsxwing] Fix a flaky test in AkkaRpcEnvSuite
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/test/scala/org/apache/spark/rpc/akka/AkkaRpcEnvSuite.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/test/scala/org/apache/spark/rpc/akka/AkkaRpcEnvSuite.scala b/core/src/test/scala/org/apache/spark/rpc/akka/AkkaRpcEnvSuite.scala index 58214c0637..a33a83db7b 100644 --- a/core/src/test/scala/org/apache/spark/rpc/akka/AkkaRpcEnvSuite.scala +++ b/core/src/test/scala/org/apache/spark/rpc/akka/AkkaRpcEnvSuite.scala @@ -40,7 +40,7 @@ class AkkaRpcEnvSuite extends RpcEnvSuite { RpcEnvConfig(conf, "test", "localhost", 12346, new SecurityManager(conf))) try { val newRef = newRpcEnv.setupEndpointRef("local", ref.address, "test_endpoint") - assert("akka.tcp://local@localhost:12345/user/test_endpoint" === + assert(s"akka.tcp://local@${env.address}/user/test_endpoint" === newRef.asInstanceOf[AkkaRpcEndpointRef].actorRef.path.toString) } finally { newRpcEnv.shutdown() |