diff options
| author | jerryshao <saisai.shao@intel.com> | 2015-04-16 10:39:02 +0100 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2015-04-16 10:39:02 +0100 |
| commit | 8370550593f3549e90ace446961281dad0cd7498 (patch) | |
| tree | 69eb929c90f0f0b439f73b04df5466da980cb4fc | |
| parent | 57cd1e86d1d450f85fc9e296aff498a940452113 (diff) | |
| download | spark-8370550593f3549e90ace446961281dad0cd7498.tar.gz spark-8370550593f3549e90ace446961281dad0cd7498.tar.bz2 spark-8370550593f3549e90ace446961281dad0cd7498.zip | |
[Streaming][minor] Remove additional quote and unneeded imports
Author: jerryshao <saisai.shao@intel.com>
Closes #5540 from jerryshao/minor-fix and squashes the following commits:
ebaa646 [jerryshao] Minor fix
| -rw-r--r-- | examples/scala-2.10/src/main/scala/org/apache/spark/examples/streaming/DirectKafkaWordCount.scala | 2 | ||||
| -rw-r--r-- | external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala | 3 |
2 files changed, 2 insertions, 3 deletions
diff --git a/examples/scala-2.10/src/main/scala/org/apache/spark/examples/streaming/DirectKafkaWordCount.scala b/examples/scala-2.10/src/main/scala/org/apache/spark/examples/streaming/DirectKafkaWordCount.scala index 1c8a20bf8f..11a8cf0953 100644 --- a/examples/scala-2.10/src/main/scala/org/apache/spark/examples/streaming/DirectKafkaWordCount.scala +++ b/examples/scala-2.10/src/main/scala/org/apache/spark/examples/streaming/DirectKafkaWordCount.scala @@ -41,7 +41,7 @@ object DirectKafkaWordCount { | <brokers> is a list of one or more Kafka brokers | <topics> is a list of one or more kafka topics to consume from | - """".stripMargin) + """.stripMargin) System.exit(1) } diff --git a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala b/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala index a0b8a0c565..a1b4a12e5d 100644 --- a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala +++ b/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala @@ -23,10 +23,9 @@ import org.apache.spark.{Logging, Partition, SparkContext, SparkException, TaskC import org.apache.spark.rdd.RDD import org.apache.spark.util.NextIterator -import java.util.Properties import kafka.api.{FetchRequestBuilder, FetchResponse} import kafka.common.{ErrorMapping, TopicAndPartition} -import kafka.consumer.{ConsumerConfig, SimpleConsumer} +import kafka.consumer.SimpleConsumer import kafka.message.{MessageAndMetadata, MessageAndOffset} import kafka.serializer.Decoder import kafka.utils.VerifiableProperties |