Skip to content
Snippets Groups Projects
Commit 14b32886 authored by zsxwing's avatar zsxwing Committed by Patrick Wendell
Browse files

[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
parent 7cf1eb79
No related branches found
No related tags found
No related merge requests found
......@@ -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()
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment