File tree Expand file tree Collapse file tree 1 file changed +1
-2
lines changed
streaming/src/main/scala/org/apache/spark/streaming/dstream Expand file tree Collapse file tree 1 file changed +1
-2
lines changed Original file line number Diff line number Diff line change 17
17
18
18
package org .apache .spark .streaming .dstream
19
19
20
+
20
21
import java .io .{IOException , ObjectInputStream , ObjectOutputStream }
21
22
22
23
import scala .deprecated
@@ -30,7 +31,6 @@ import org.apache.spark.streaming._
30
31
import org .apache .spark .streaming .StreamingContext ._
31
32
import org .apache .spark .streaming .scheduler .Job
32
33
import org .apache .spark .util .MetadataCleaner
33
- import org .apache .spark .streaming .Duration
34
34
35
35
/**
36
36
* A Discretized Stream (DStream), the basic abstraction in Spark Streaming, is a continuous
@@ -557,7 +557,6 @@ abstract class DStream[T: ClassTag] (
557
557
// because the DStream is reachable from the outer object here, and because
558
558
// DStreams can't be serialized with closures, we can't proactively check
559
559
// it for serializability and so we pass the optional false to SparkContext.clean
560
-
561
560
val cleanedF = context.sparkContext.clean(transformFunc, false )
562
561
val realTransformFunc = (rdds : Seq [RDD [_]], time : Time ) => {
563
562
assert(rdds.length == 1 )
You can’t perform that action at this time.
0 commit comments