From af610d3ba888f411162ef19384409929a1592e3c Mon Sep 17 00:00:00 2001 From: giwa Date: Mon, 11 Aug 2014 04:42:08 -0700 Subject: [PATCH] removed unnesessary changes --- .../scala/org/apache/spark/streaming/dstream/DStream.scala | 3 --- 1 file changed, 3 deletions(-) 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 index 15ead505eac5b..46ef05d9c37a1 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/dstream/DStream.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/dstream/DStream.scala @@ -22,8 +22,6 @@ import java.io.{IOException, ObjectInputStream, ObjectOutputStream} import scala.deprecated import scala.collection.mutable.HashMap import scala.reflect.ClassTag -import java.io.{IOException, ObjectInputStream, ObjectOutputStream} -import scala.util.control.Breaks._ import org.apache.spark.{Logging, SparkException} import org.apache.spark.rdd.{BlockRDD, RDD} @@ -563,7 +561,6 @@ abstract class DStream[T: ClassTag] ( val cleanedF = context.sparkContext.clean(transformFunc, false) val realTransformFunc = (rdds: Seq[RDD[_]], time: Time) => { assert(rdds.length == 1) - // if transformfunc is fine, it is okay cleanedF(rdds.head.asInstanceOf[RDD[T]], time) } new TransformedDStream[U](Seq(this), realTransformFunc)