Skip to content

Commit 8370550

Browse files
jerryshaosrowen
authored andcommitted
[Streaming][minor] Remove additional quote and unneeded imports
Author: jerryshao <[email protected]> Closes apache#5540 from jerryshao/minor-fix and squashes the following commits: ebaa646 [jerryshao] Minor fix
1 parent 57cd1e8 commit 8370550

File tree

2 files changed

+2
-3
lines changed

2 files changed

+2
-3
lines changed

examples/scala-2.10/src/main/scala/org/apache/spark/examples/streaming/DirectKafkaWordCount.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,7 @@ object DirectKafkaWordCount {
4141
| <brokers> is a list of one or more Kafka brokers
4242
| <topics> is a list of one or more kafka topics to consume from
4343
|
44-
"""".stripMargin)
44+
""".stripMargin)
4545
System.exit(1)
4646
}
4747

external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,10 +23,9 @@ import org.apache.spark.{Logging, Partition, SparkContext, SparkException, TaskC
2323
import org.apache.spark.rdd.RDD
2424
import org.apache.spark.util.NextIterator
2525

26-
import java.util.Properties
2726
import kafka.api.{FetchRequestBuilder, FetchResponse}
2827
import kafka.common.{ErrorMapping, TopicAndPartition}
29-
import kafka.consumer.{ConsumerConfig, SimpleConsumer}
28+
import kafka.consumer.SimpleConsumer
3029
import kafka.message.{MessageAndMetadata, MessageAndOffset}
3130
import kafka.serializer.Decoder
3231
import kafka.utils.VerifiableProperties

0 commit comments

Comments
 (0)