diff options
| author | Prashant Sharma <prashant.s@imaginea.com> | 2013-04-29 19:56:28 +0530 |
|---|---|---|
| committer | Prashant Sharma <prashant.s@imaginea.com> | 2013-04-29 19:56:28 +0530 |
| commit | 24bbf318b3e8e657f911204b84f2d032fb1ff6e2 (patch) | |
| tree | 8f9f2233f20a9bbd860e456a8e83ab856a53e3b8 /streaming | |
| parent | d3518f57cd833f6297860c6344e685b9bf0210f5 (diff) | |
| download | spark-24bbf318b3e8e657f911204b84f2d032fb1ff6e2.tar.gz spark-24bbf318b3e8e657f911204b84f2d032fb1ff6e2.tar.bz2 spark-24bbf318b3e8e657f911204b84f2d032fb1ff6e2.zip | |
Fixied other warnings
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/main/scala/spark/streaming/DStream.scala | 4 |
1 files changed, 1 insertions, 3 deletions
diff --git a/streaming/src/main/scala/spark/streaming/DStream.scala b/streaming/src/main/scala/spark/streaming/DStream.scala index c307c69611..6ad43dd9b5 100644 --- a/streaming/src/main/scala/spark/streaming/DStream.scala +++ b/streaming/src/main/scala/spark/streaming/DStream.scala @@ -466,9 +466,7 @@ abstract class DStream[T: ClassTag] ( * this DStream will be registered as an output stream and therefore materialized. */ def foreach(foreachFunc: (RDD[T], Time) => Unit) { - val newStream = new ForEachDStream(this, context.sparkContext.clean(foreachFunc)) - ssc.registerOutputStream(newStream) - newStream + ssc.registerOutputStream(new ForEachDStream(this, context.sparkContext.clean(foreachFunc))) } /** |