You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by pw...@apache.org on 2015/05/01 08:42:21 UTC
spark git commit: [SPARK-7291] [CORE] Fix a flaky test in
AkkaRpcEnvSuite
Repository: spark
Updated Branches:
refs/heads/master 7cf1eb79b -> 14b32886f
[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 <zs...@gmail.com>
Closes #5822 from zsxwing/SPARK-7291 and squashes the following commits:
e521b84 [zsxwing] Fix a flaky test in AkkaRpcEnvSuite
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/14b32886
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/14b32886
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/14b32886
Branch: refs/heads/master
Commit: 14b32886fa01aef6cc0dfbc263eb6d4c9d2876fa
Parents: 7cf1eb7
Author: zsxwing <zs...@gmail.com>
Authored: Thu Apr 30 23:44:33 2015 -0700
Committer: Patrick Wendell <pa...@databricks.com>
Committed: Thu Apr 30 23:44:33 2015 -0700
----------------------------------------------------------------------
.../src/test/scala/org/apache/spark/rpc/akka/AkkaRpcEnvSuite.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/14b32886/core/src/test/scala/org/apache/spark/rpc/akka/AkkaRpcEnvSuite.scala
----------------------------------------------------------------------
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 58214c0..a33a83d 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()
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org