aboutsummaryrefslogtreecommitdiff
path: root/examples
diff options
context:
space:
mode:
authorMatei Zaharia <matei@eecs.berkeley.edu>2011-12-01 13:52:12 -0800
committerMatei Zaharia <matei@eecs.berkeley.edu>2011-12-01 13:52:12 -0800
commit72c4839c5f7c89194cc1865bb875dddb1ab87f01 (patch)
tree85721e8e48505a24b3d6875ca7877ee1e42256a3 /examples
parent22b8fcf632de8e00d25ab529eb347ed2288e20fc (diff)
downloadspark-72c4839c5f7c89194cc1865bb875dddb1ab87f01.tar.gz
spark-72c4839c5f7c89194cc1865bb875dddb1ab87f01.tar.bz2
spark-72c4839c5f7c89194cc1865bb875dddb1ab87f01.zip
Fixed LocalFileLR to deal with a change in Scala IO sources
(you can no longer iterate over a Source multiple times).
Diffstat (limited to 'examples')
-rw-r--r--examples/src/main/scala/spark/examples/LocalFileLR.scala2
1 files changed, 1 insertions, 1 deletions
diff --git a/examples/src/main/scala/spark/examples/LocalFileLR.scala b/examples/src/main/scala/spark/examples/LocalFileLR.scala
index 2e94ccbec2..b819fe80fe 100644
--- a/examples/src/main/scala/spark/examples/LocalFileLR.scala
+++ b/examples/src/main/scala/spark/examples/LocalFileLR.scala
@@ -15,7 +15,7 @@ object LocalFileLR {
}
def main(args: Array[String]) {
- val lines = scala.io.Source.fromFile(args(0)).getLines()
+ val lines = scala.io.Source.fromFile(args(0)).getLines().toArray
val points = lines.map(parsePoint _)
val ITERATIONS = args(1).toInt