diff options
| -rw-r--r-- | examples/src/main/scala/spark/examples/SparkPi.scala | 3 | ||||
| -rw-r--r-- | run2.cmd | 2 |
2 files changed, 3 insertions, 2 deletions
diff --git a/examples/src/main/scala/spark/examples/SparkPi.scala b/examples/src/main/scala/spark/examples/SparkPi.scala index f598d2ff9c..b1c736a2cd 100644 --- a/examples/src/main/scala/spark/examples/SparkPi.scala +++ b/examples/src/main/scala/spark/examples/SparkPi.scala @@ -21,6 +21,7 @@ object SparkPi { if (x*x + y*y < 1) 1 else 0 }.reduce(_ + _) println("Pi is roughly " + 4.0 * count / n) - System.exit(0) + //System.exit(0) + spark.stop() } } @@ -1,6 +1,6 @@ @echo off -set SCALA_VERSION=2.9.3 +set SCALA_VERSION=2.10 rem Figure out where the Spark framework is installed set FWDIR=%~dp0 |