Fix tests?

Andrew Or · Andrew Or · commit 65ef07b8c5b0 · 2015-05-19T18:50:16.000-07:00
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/dstream/DStream.scala b/streaming/src/main/scala/org/apache/spark/streaming/dstream/DStream.scala
@@ -624,7 +624,7 @@ abstract class DStream[T: ClassTag] (
    * 'this' DStream will be registered as an output stream and therefore materialized.
    */
   def foreachRDD(foreachFunc: RDD[T] => Unit): Unit = ssc.withScope {
-    val cleanedF = context.sparkContext.clean(foreachFunc)
+    val cleanedF = context.sparkContext.clean(foreachFunc, false)
     this.foreachRDD((r: RDD[T], t: Time) => cleanedF(r))
   }
 

Original file line number	Diff line number	Diff line change
`@@ -624,7 +624,7 @@ abstract class DStream[T: ClassTag] (`
`624`	`624`	`* 'this' DStream will be registered as an output stream and therefore materialized.`
`625`	`625`	`*/`
`626`	`626`	`def foreachRDD(foreachFunc: RDD[T] => Unit): Unit = ssc.withScope {`
`627`		`- val cleanedF = context.sparkContext.clean(foreachFunc)`
	`627`	`+ val cleanedF = context.sparkContext.clean(foreachFunc, false)`
`628`	`628`	`this.foreachRDD((r: RDD[T], t: Time) => cleanedF(r))`
`629`	`629`	`}`
`630`	`630`