diff options
| author | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-02-04 11:06:31 -0800 |
|---|---|---|
| committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2013-02-04 11:06:31 -0800 |
| commit | aa4ee1e9e5485c1b96474e704c76225a2b8a7da9 (patch) | |
| tree | ea973b24fc061cdf6226d42b256d1dc7a0bf3f5d | |
| parent | f7b4e428be75d189b9ae50c4302c08f3c49e0161 (diff) | |
| download | spark-aa4ee1e9e5485c1b96474e704c76225a2b8a7da9.tar.gz spark-aa4ee1e9e5485c1b96474e704c76225a2b8a7da9.tar.bz2 spark-aa4ee1e9e5485c1b96474e704c76225a2b8a7da9.zip | |
Fix failing test
| -rw-r--r-- | core/src/test/scala/spark/MapOutputTrackerSuite.scala | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/core/src/test/scala/spark/MapOutputTrackerSuite.scala b/core/src/test/scala/spark/MapOutputTrackerSuite.scala index f4e7ec39fe..dd19442dcb 100644 --- a/core/src/test/scala/spark/MapOutputTrackerSuite.scala +++ b/core/src/test/scala/spark/MapOutputTrackerSuite.scala @@ -79,8 +79,7 @@ class MapOutputTrackerSuite extends FunSuite with LocalSparkContext { test("remote fetch") { try { System.clearProperty("spark.driver.host") // In case some previous test had set it - val (actorSystem, boundPort) = - AkkaUtils.createActorSystem("test", "localhost", 0) + val (actorSystem, boundPort) = AkkaUtils.createActorSystem("spark", "localhost", 0) System.setProperty("spark.driver.port", boundPort.toString) val masterTracker = new MapOutputTracker(actorSystem, true) val slaveTracker = new MapOutputTracker(actorSystem, false) |