diff options
| -rw-r--r-- | core/src/main/scala/spark/deploy/LocalSparkCluster.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/deploy/LocalSparkCluster.scala b/core/src/main/scala/spark/deploy/LocalSparkCluster.scala index 85a7b65c38..4f37cd5f83 100644 --- a/core/src/main/scala/spark/deploy/LocalSparkCluster.scala +++ b/core/src/main/scala/spark/deploy/LocalSparkCluster.scala @@ -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 { |