From 87b915f22105ced8b9cad2a1262a0fd26542ee4f Mon Sep 17 00:00:00 2001 From: Tathagata Das Date: Tue, 31 Dec 2013 00:42:10 -0800 Subject: Removed extra empty lines. --- .../main/scala/org/apache/spark/streaming/kafka/KafkaInputDStream.scala | 1 - 1 file changed, 1 deletion(-) (limited to 'external/kafka') diff --git a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaInputDStream.scala b/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaInputDStream.scala index fd69328aba..a2cd49c573 100644 --- a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaInputDStream.scala +++ b/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaInputDStream.scala @@ -34,7 +34,6 @@ import org.apache.spark.storage.StorageLevel import org.apache.spark.streaming.StreamingContext import org.apache.spark.streaming.dstream._ - /** * Input stream that pulls messages from a Kafka Broker. * -- cgit v1.2.3