aboutsummaryrefslogtreecommitdiff
path: root/external/zeromq/src/test/scala/org
diff options
context:
space:
mode:
authorPrashant Sharma <prashant.s@imaginea.com>2014-11-19 14:18:10 -0800
committerPatrick Wendell <pwendell@gmail.com>2014-11-19 14:18:10 -0800
commit1c938413ba5579034675f1b4ea3b8fd0e47dd8d6 (patch)
treefc551db455e7e07b292a1dfdba5ecb16b75473af /external/zeromq/src/test/scala/org
parent0df02ca463a4126e5437b37114c6759a57ab71ee (diff)
downloadspark-1c938413ba5579034675f1b4ea3b8fd0e47dd8d6.tar.gz
spark-1c938413ba5579034675f1b4ea3b8fd0e47dd8d6.tar.bz2
spark-1c938413ba5579034675f1b4ea3b8fd0e47dd8d6.zip
SPARK-3962 Marked scope as provided for external projects.
Somehow maven shade plugin is set in infinite loop of creating effective pom. Author: Prashant Sharma <prashant.s@imaginea.com> Author: Prashant Sharma <scrapcodes@gmail.com> Closes #2959 from ScrapCodes/SPARK-3962/scope-provided and squashes the following commits: 994d1d3 [Prashant Sharma] Fixed failing flume tests 270b4fb [Prashant Sharma] Removed most of the unused code. bb3bbfd [Prashant Sharma] SPARK-3962 Marked scope as provided for external.
Diffstat (limited to 'external/zeromq/src/test/scala/org')
-rw-r--r--external/zeromq/src/test/scala/org/apache/spark/streaming/zeromq/ZeroMQStreamSuite.scala11
1 files changed, 9 insertions, 2 deletions
diff --git a/external/zeromq/src/test/scala/org/apache/spark/streaming/zeromq/ZeroMQStreamSuite.scala b/external/zeromq/src/test/scala/org/apache/spark/streaming/zeromq/ZeroMQStreamSuite.scala
index cc10ff6ae0..a7566e733d 100644
--- a/external/zeromq/src/test/scala/org/apache/spark/streaming/zeromq/ZeroMQStreamSuite.scala
+++ b/external/zeromq/src/test/scala/org/apache/spark/streaming/zeromq/ZeroMQStreamSuite.scala
@@ -20,12 +20,19 @@ package org.apache.spark.streaming.zeromq
import akka.actor.SupervisorStrategy
import akka.util.ByteString
import akka.zeromq.Subscribe
+import org.scalatest.FunSuite
import org.apache.spark.storage.StorageLevel
-import org.apache.spark.streaming.{StreamingContext, TestSuiteBase}
+import org.apache.spark.streaming.{Seconds, StreamingContext}
import org.apache.spark.streaming.dstream.ReceiverInputDStream
-class ZeroMQStreamSuite extends TestSuiteBase {
+class ZeroMQStreamSuite extends FunSuite {
+
+ val batchDuration = Seconds(1)
+
+ private val master: String = "local[2]"
+
+ private val framework: String = this.getClass.getSimpleName
test("zeromq input stream") {
val ssc = new StreamingContext(master, framework, batchDuration)