ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

[Streaming][minor] Remove additional quote and unneeded imports

Browse source 
Author: jerryshao <saisai.shao@intel.com>

Closes #5540 from jerryshao/minor-fix and squashes the following commits:

ebaa646 [jerryshao] Minor fix
This commit is contained in:
jerryshao 2015-04-16 10:39:02 +01:00 committed by Sean Owen
parent 57cd1e86d1
commit 8370550593
2 changed files with 2 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -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)
}

3
external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDD.scala vendored
View file

@ -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