diff options
| author | Denny <dennybritz@gmail.com> | 2012-09-04 22:04:18 -0700 |
|---|---|---|
| committer | Denny <dennybritz@gmail.com> | 2012-09-04 22:04:18 -0700 |
| commit | babbca0a2fe00b43199d60f0241ffe36f0c31f48 (patch) | |
| tree | 48924e31986ed495e2c78b7d726843d73ffd9a48 | |
| parent | 9326509f66d659219924e1e9235f4560986dc579 (diff) | |
| download | spark-babbca0a2fe00b43199d60f0241ffe36f0c31f48.tar.gz spark-babbca0a2fe00b43199d60f0241ffe36f0c31f48.tar.bz2 spark-babbca0a2fe00b43199d60f0241ffe36f0c31f48.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 { |