From 8d2cd51b324a8d118f05e1bcc95f947d055e6275 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?baishuo=28=E7=99=BD=E7=A1=95=29?= Date: Sat, 14 Jun 2014 19:57:25 +0800 Subject: [PATCH 1/2] Update BasicOperationsSuite.scala use the full package name for ManualClock --- .../scala/org/apache/spark/streaming/BasicOperationsSuite.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/streaming/src/test/scala/org/apache/spark/streaming/BasicOperationsSuite.scala b/streaming/src/test/scala/org/apache/spark/streaming/BasicOperationsSuite.scala index ff6d86c8f81ac..f2bdacb94352a 100644 --- a/streaming/src/test/scala/org/apache/spark/streaming/BasicOperationsSuite.scala +++ b/streaming/src/test/scala/org/apache/spark/streaming/BasicOperationsSuite.scala @@ -22,7 +22,7 @@ import org.apache.spark.streaming.StreamingContext._ import org.apache.spark.rdd.{BlockRDD, RDD} import org.apache.spark.SparkContext._ -import util.ManualClock +import org.apache.spark.streaming.util.ManualClock import org.apache.spark.{SparkException, SparkConf} import org.apache.spark.streaming.dstream.{WindowedDStream, DStream} import scala.collection.mutable.{SynchronizedBuffer, ArrayBuffer} From 453a2d3de7ab794889d796e968e3586100971c60 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?baishuo=28=E7=99=BD=E7=A1=95=29?= Date: Sun, 15 Jun 2014 16:50:33 +0800 Subject: [PATCH 2/2] Update BasicOperationsSuite.scala --- .../spark/streaming/BasicOperationsSuite.scala | 15 ++++++--------- 1 file changed, 6 insertions(+), 9 deletions(-) diff --git a/streaming/src/test/scala/org/apache/spark/streaming/BasicOperationsSuite.scala b/streaming/src/test/scala/org/apache/spark/streaming/BasicOperationsSuite.scala index f2bdacb94352a..1b0ac83dde18d 100644 --- a/streaming/src/test/scala/org/apache/spark/streaming/BasicOperationsSuite.scala +++ b/streaming/src/test/scala/org/apache/spark/streaming/BasicOperationsSuite.scala @@ -17,18 +17,15 @@ package org.apache.spark.streaming -import org.apache.spark.streaming.StreamingContext._ - import org.apache.spark.rdd.{BlockRDD, RDD} -import org.apache.spark.SparkContext._ - +import org.apache.spark.storage.StorageLevel +import org.apache.spark.streaming.dstream.{DStream, WindowedDStream} import org.apache.spark.streaming.util.ManualClock -import org.apache.spark.{SparkException, SparkConf} -import org.apache.spark.streaming.dstream.{WindowedDStream, DStream} -import scala.collection.mutable.{SynchronizedBuffer, ArrayBuffer} +import org.apache.spark.streaming.StreamingContext._ +import org.apache.spark.SparkContext._ +import org.apache.spark.{SparkConf, SparkException} +import scala.collection.mutable.{ArrayBuffer, SynchronizedBuffer} import scala.reflect.ClassTag -import org.apache.spark.storage.StorageLevel -import scala.collection.mutable class BasicOperationsSuite extends TestSuiteBase { test("map") {