This commit is contained in:
Denny 2012-09-04 22:04:18 -07:00
Родитель 93fe331e6d
Коммит a367c20f49
1 изменённых файлов: 1 добавлений и 1 удалений

Просмотреть файл

@ -38,7 +38,7 @@ class LocalSparkCluster(numSlaves : Int, coresPerSlave : Int,
})
/* Start the Slaves */
(1 to numSlaves + 1).foreach { slaveNum =>
(1 to numSlaves).foreach { slaveNum =>
val (actorSystem, boundPort) =
AkkaUtils.createActorSystem("sparkWorker" + slaveNum, localIpAddress, 0)
threadPool.execute(new Runnable {