Skip to content

Commit af610d3

Browse files
committed
removed unnesessary changes
1 parent c1d546e commit af610d3

File tree

1 file changed

+0
-3
lines changed
  • streaming/src/main/scala/org/apache/spark/streaming/dstream

1 file changed

+0
-3
lines changed

streaming/src/main/scala/org/apache/spark/streaming/dstream/DStream.scala

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -22,8 +22,6 @@ import java.io.{IOException, ObjectInputStream, ObjectOutputStream}
2222
import scala.deprecated
2323
import scala.collection.mutable.HashMap
2424
import scala.reflect.ClassTag
25-
import java.io.{IOException, ObjectInputStream, ObjectOutputStream}
26-
import scala.util.control.Breaks._
2725

2826
import org.apache.spark.{Logging, SparkException}
2927
import org.apache.spark.rdd.{BlockRDD, RDD}
@@ -563,7 +561,6 @@ abstract class DStream[T: ClassTag] (
563561
val cleanedF = context.sparkContext.clean(transformFunc, false)
564562
val realTransformFunc = (rdds: Seq[RDD[_]], time: Time) => {
565563
assert(rdds.length == 1)
566-
// if transformfunc is fine, it is okay
567564
cleanedF(rdds.head.asInstanceOf[RDD[T]], time)
568565
}
569566
new TransformedDStream[U](Seq(this), realTransformFunc)

0 commit comments

Comments
 (0)