Merge pull request #606 from markhamstra/foreachPartition_fix

Actually use the cleaned closure in foreachPartition

core/src/main/scala/spark/RDD.scala

@@ -489,7 +489,7 @@ abstract class RDD[T: ClassManifest](
    */
   def foreachPartition(f: Iterator[T] => Unit) {
     val cleanF = sc.clean(f)
-    sc.runJob(this, (iter: Iterator[T]) => f(iter))
+    sc.runJob(this, (iter: Iterator[T]) => cleanF(iter))
   }
 
   /**