From 4f82c89e5974acd56612ca3649dcaf6a0856dbf7 Mon Sep 17 00:00:00 2001 From: giwa Date: Wed, 20 Aug 2014 19:30:36 -0700 Subject: [PATCH] remove duplicated import --- .../scala/org/apache/spark/streaming/dstream/DStream.scala | 3 +-- 1 file changed, 1 insertion(+), 2 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 39ad591e8896e..e05db236addca 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 @@ -17,6 +17,7 @@ package org.apache.spark.streaming.dstream + import java.io.{IOException, ObjectInputStream, ObjectOutputStream} import scala.deprecated @@ -30,7 +31,6 @@ import org.apache.spark.streaming._ import org.apache.spark.streaming.StreamingContext._ import org.apache.spark.streaming.scheduler.Job import org.apache.spark.util.MetadataCleaner -import org.apache.spark.streaming.Duration /** * A Discretized Stream (DStream), the basic abstraction in Spark Streaming, is a continuous @@ -557,7 +557,6 @@ abstract class DStream[T: ClassTag] ( // because the DStream is reachable from the outer object here, and because // DStreams can't be serialized with closures, we can't proactively check // it for serializability and so we pass the optional false to SparkContext.clean - val cleanedF = context.sparkContext.clean(transformFunc, false) val realTransformFunc = (rdds: Seq[RDD[_]], time: Time) => { assert(rdds.length == 1)