diff options
| author | Patrick Wendell <pwendell@gmail.com> | 2013-10-24 16:43:33 -0700 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2013-10-24 16:43:33 -0700 |
| commit | 39f6f75588b69f07cd963c5e211045fed103695b (patch) | |
| tree | c6ba252990d9a970373f99e6291787b79bcb3628 /streaming/src/test/java | |
| parent | 9423532fab4d58ac05f283ac2e9baddc3ee48928 (diff) | |
| download | spark-39f6f75588b69f07cd963c5e211045fed103695b.tar.gz spark-39f6f75588b69f07cd963c5e211045fed103695b.tar.bz2 spark-39f6f75588b69f07cd963c5e211045fed103695b.zip | |
Some clean-up of tests
Diffstat (limited to 'streaming/src/test/java')
| -rw-r--r-- | streaming/src/test/java/org/apache/spark/streaming/JavaTestUtils.scala | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/streaming/src/test/java/org/apache/spark/streaming/JavaTestUtils.scala b/streaming/src/test/java/org/apache/spark/streaming/JavaTestUtils.scala index 8a6604904d..5344ae7682 100644 --- a/streaming/src/test/java/org/apache/spark/streaming/JavaTestUtils.scala +++ b/streaming/src/test/java/org/apache/spark/streaming/JavaTestUtils.scala @@ -54,8 +54,7 @@ trait JavaTestBase extends TestSuiteBase { { implicit val cm: ClassManifest[T] = implicitly[ClassManifest[AnyRef]].asInstanceOf[ClassManifest[T]] - val ostream = new TestOutputStream(dstream.dstream, - new ArrayBuffer[Seq[T]] with SynchronizedBuffer[Seq[T]]) + val ostream = new TestOutputStreamWithPartitions(dstream.dstream) dstream.dstream.ssc.registerOutputStream(ostream) } |