diff options
| author | Denny <dennybritz@gmail.com> | 2012-09-04 22:04:18 -0700 |
|---|---|---|
| committer | Denny <dennybritz@gmail.com> | 2012-09-10 12:48:57 -0700 |
| commit | a367c20f4907dddecda64a3f1d67171556fa6ba0 (patch) | |
| tree | 09f4f5e8229ca8085d35e89989553e636eba300f | |
| parent | 93fe331e6d572b7f5497f59a283d63374809c9a4 (diff) | |
| download | spark-a367c20f4907dddecda64a3f1d67171556fa6ba0.tar.gz spark-a367c20f4907dddecda64a3f1d67171556fa6ba0.tar.bz2 spark-a367c20f4907dddecda64a3f1d67171556fa6ba0.zip | |
Fix wrong counting
| -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 { |