diff options
Diffstat (limited to 'external/kafka/src/test/scala/org/apache/spark/streaming/kafka/KafkaStreamSuite.scala')
| -rw-r--r-- | external/kafka/src/test/scala/org/apache/spark/streaming/kafka/KafkaStreamSuite.scala | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/external/kafka/src/test/scala/org/apache/spark/streaming/kafka/KafkaStreamSuite.scala b/external/kafka/src/test/scala/org/apache/spark/streaming/kafka/KafkaStreamSuite.scala index 9c81f23c19..d9809f6409 100644 --- a/external/kafka/src/test/scala/org/apache/spark/streaming/kafka/KafkaStreamSuite.scala +++ b/external/kafka/src/test/scala/org/apache/spark/streaming/kafka/KafkaStreamSuite.scala @@ -35,5 +35,6 @@ class KafkaStreamSuite extends TestSuiteBase { ssc, kafkaParams, topics, StorageLevel.MEMORY_AND_DISK_SER_2) // TODO: Actually test receiving data + ssc.stop() } } |