Correct variable name

tedyu · tedyu · commit 164d3e408c7d · 2015-05-07T16:28:03.000-07:00
diff --git a/core/src/main/scala/org/apache/spark/rdd/RDD.scala b/core/src/main/scala/org/apache/spark/rdd/RDD.scala
@@ -717,7 +717,7 @@ abstract class RDD[T: ClassTag](
   def mapPartitionsWithContext[U: ClassTag](
       f: (TaskContext, Iterator[T]) => Iterator[U],
       preservesPartitioning: Boolean = false): RDD[U] = withScope {
-    val cleanedF = sc.clean(f)
+    val cleanF = sc.clean(f)
     val func = (context: TaskContext, index: Int, iter: Iterator[T]) => cleanF(context, iter)
     new MapPartitionsRDD(this, sc.clean(func), preservesPartitioning)
   }

Original file line number	Diff line number	Diff line change
`@@ -717,7 +717,7 @@ abstract class RDD[T: ClassTag](`
`717`	`717`	`def mapPartitionsWithContext[U: ClassTag](`
`718`	`718`	`f: (TaskContext, Iterator[T]) => Iterator[U],`
`719`	`719`	`preservesPartitioning: Boolean = false): RDD[U] = withScope {`
`720`		`- val cleanedF = sc.clean(f)`
	`720`	`+ val cleanF = sc.clean(f)`
`721`	`721`	`val func = (context: TaskContext, index: Int, iter: Iterator[T]) => cleanF(context, iter)`
`722`	`722`	`new MapPartitionsRDD(this, sc.clean(func), preservesPartitioning)`
`723`	`723`	`}`