diff options
| author | Tathagata Das <tathagata.das1565@gmail.com> | 2013-12-23 15:55:45 -0800 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2013-12-23 15:55:45 -0800 |
| commit | 6eaa0505493511adb040257abc749fcd774bbb68 (patch) | |
| tree | 755d6eb32a5661ec4b00ffc4c0d32942a57694d5 /streaming | |
| parent | f9771690a698b6ce5d29eb36b38bbeb498d1af0d (diff) | |
| download | spark-6eaa0505493511adb040257abc749fcd774bbb68.tar.gz spark-6eaa0505493511adb040257abc749fcd774bbb68.tar.bz2 spark-6eaa0505493511adb040257abc749fcd774bbb68.zip | |
Minor change for PR 277.
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/test/scala/org/apache/spark/streaming/StreamingListenerSuite.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/streaming/src/test/scala/org/apache/spark/streaming/StreamingListenerSuite.scala b/streaming/src/test/scala/org/apache/spark/streaming/StreamingListenerSuite.scala index 16410a21e3..fa64142096 100644 --- a/streaming/src/test/scala/org/apache/spark/streaming/StreamingListenerSuite.scala +++ b/streaming/src/test/scala/org/apache/spark/streaming/StreamingListenerSuite.scala @@ -21,7 +21,7 @@ import org.apache.spark.streaming.scheduler._ import scala.collection.mutable.ArrayBuffer import org.scalatest.matchers.ShouldMatchers -class StreamingListenerSuite extends TestSuiteBase with ShouldMatchers{ +class StreamingListenerSuite extends TestSuiteBase with ShouldMatchers { val input = (1 to 4).map(Seq(_)).toSeq val operation = (d: DStream[Int]) => d.map(x => x) |