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 /external/kafka/src/main | |
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
Diffstat (limited to 'external/kafka/src/main')
-rw-r--r-- | external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala | 3 |
1 files changed, 1 insertions, 2 deletions
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 |