From a2c01ae5e3489b6c21a4c7bcc1ec615069ff4829 Mon Sep 17 00:00:00 2001 From: Tathagata Das Date: Tue, 25 Nov 2014 15:27:20 -0800 Subject: [HOTFIX] Fixing broken build due to missing imports. --- .../scala/org/apache/spark/streaming/dstream/PairDStreamFunctions.scala | 1 + 1 file changed, 1 insertion(+) diff --git a/streaming/src/main/scala/org/apache/spark/streaming/dstream/PairDStreamFunctions.scala b/streaming/src/main/scala/org/apache/spark/streaming/dstream/PairDStreamFunctions.scala index 806fe5f83e..a4b5ae4a55 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/dstream/PairDStreamFunctions.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/dstream/PairDStreamFunctions.scala @@ -26,6 +26,7 @@ import org.apache.hadoop.mapreduce.{OutputFormat => NewOutputFormat} import org.apache.spark.{HashPartitioner, Partitioner, SerializableWritable} import org.apache.spark.rdd.RDD +import org.apache.spark.SparkContext._ import org.apache.spark.streaming.{Duration, Time} import org.apache.spark.streaming.StreamingContext._ -- cgit v1.2.3