Update Main.scala

Author: helenahm

spark-scala/src/main/scala/com/matthewrathbone/spark/Main.scala

@@ -30,11 +30,12 @@ object Main {
 	val r = sc.parallelize(result.toSeq).map(t => (t._1.toString, t._2.toString))
 
 	r.saveAsTextFile(args(2))
+	sc.stop()
   }
 
 
   def processData (t: RDD[(Int, Int)], u: RDD[(Int, String)]) : Map[Int,Long] = {
 	var jn = t.leftOuterJoin(u).values.distinct
 	return jn.countByKey
   }
-}
+}