diff options
| author | uncleGen <hustyugm@gmail.com> | 2017-01-18 09:44:32 +0000 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2017-01-18 09:44:32 +0000 |
| commit | eefdf9f9dd8afde49ad7d4e230e2735eb817ab0a (patch) | |
| tree | b265b1f01f194765ae90bc973ee4be72e4891c81 /external/kafka-0-10-sql | |
| parent | 4494cd9716d64a6c7cfa548abadb5dd0c4c143a6 (diff) | |
| download | spark-eefdf9f9dd8afde49ad7d4e230e2735eb817ab0a.tar.gz spark-eefdf9f9dd8afde49ad7d4e230e2735eb817ab0a.tar.bz2 spark-eefdf9f9dd8afde49ad7d4e230e2735eb817ab0a.zip | |
[SPARK-19227][SPARK-19251] remove unused imports and outdated comments
## What changes were proposed in this pull request?
remove ununsed imports and outdated comments, and fix some minor code style issue.
## How was this patch tested?
existing ut
Author: uncleGen <hustyugm@gmail.com>
Closes #16591 from uncleGen/SPARK-19227.
Diffstat (limited to 'external/kafka-0-10-sql')
| -rw-r--r-- | external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaSource.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaSource.scala b/external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaSource.scala index 43b8d9d6d7..8e6c93e672 100644 --- a/external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaSource.scala +++ b/external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaSource.scala @@ -24,7 +24,7 @@ import java.nio.charset.StandardCharsets import scala.collection.JavaConverters._ import scala.util.control.NonFatal -import org.apache.kafka.clients.consumer.{Consumer, ConsumerConfig, KafkaConsumer, OffsetOutOfRangeException} +import org.apache.kafka.clients.consumer.{Consumer, ConsumerConfig, KafkaConsumer} import org.apache.kafka.clients.consumer.internals.NoOpConsumerRebalanceListener import org.apache.kafka.common.TopicPartition |