diff options
| author | Lian, Cheng <rhythm.mail@gmail.com> | 2014-01-06 11:21:35 +0800 |
|---|---|---|
| committer | Lian, Cheng <rhythm.mail@gmail.com> | 2014-01-06 11:26:59 +0800 |
| commit | eb24684748da5dc2495fc4afe6da58edb463294b (patch) | |
| tree | 5edc651e3cc22ba2843e450b4601528ad3fa8498 /core/src | |
| parent | 5c152e3e219a44f97d9df38ba00cdc4adbf4d873 (diff) | |
| download | spark-eb24684748da5dc2495fc4afe6da58edb463294b.tar.gz spark-eb24684748da5dc2495fc4afe6da58edb463294b.tar.bz2 spark-eb24684748da5dc2495fc4afe6da58edb463294b.zip | |
Fixed test suite compilation errors
Diffstat (limited to 'core/src')
| -rw-r--r-- | core/src/test/scala/org/apache/spark/MapOutputTrackerSuite.scala | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/core/src/test/scala/org/apache/spark/MapOutputTrackerSuite.scala b/core/src/test/scala/org/apache/spark/MapOutputTrackerSuite.scala index 82dc30ecc4..afc1beff98 100644 --- a/core/src/test/scala/org/apache/spark/MapOutputTrackerSuite.scala +++ b/core/src/test/scala/org/apache/spark/MapOutputTrackerSuite.scala @@ -50,14 +50,14 @@ class MapOutputTrackerSuite extends FunSuite with LocalSparkContext { test("master start and stop") { val actorSystem = ActorSystem("test") val tracker = new MapOutputTrackerMaster(conf) - tracker.trackerActor = Left(actorSystem.actorOf(Props(new MapOutputTrackerMasterActor(tracker)))) + tracker.trackerActor = actorSystem.actorOf(Props(new MapOutputTrackerMasterActor(tracker))) tracker.stop() } test("master register and fetch") { val actorSystem = ActorSystem("test") val tracker = new MapOutputTrackerMaster(conf) - tracker.trackerActor = Left(actorSystem.actorOf(Props(new MapOutputTrackerMasterActor(tracker)))) + tracker.trackerActor = actorSystem.actorOf(Props(new MapOutputTrackerMasterActor(tracker))) tracker.registerShuffle(10, 2) val compressedSize1000 = MapOutputTracker.compressSize(1000L) val compressedSize10000 = MapOutputTracker.compressSize(10000L) @@ -76,7 +76,7 @@ class MapOutputTrackerSuite extends FunSuite with LocalSparkContext { test("master register and unregister and fetch") { val actorSystem = ActorSystem("test") val tracker = new MapOutputTrackerMaster(conf) - tracker.trackerActor = Left(actorSystem.actorOf(Props(new MapOutputTrackerMasterActor(tracker)))) + tracker.trackerActor = actorSystem.actorOf(Props(new MapOutputTrackerMasterActor(tracker))) tracker.registerShuffle(10, 2) val compressedSize1000 = MapOutputTracker.compressSize(1000L) val compressedSize10000 = MapOutputTracker.compressSize(10000L) |