We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 5697a01 commit 98c8d17Copy full SHA for 98c8d17
python/pyspark/streaming/kafka.py
@@ -74,7 +74,7 @@ def getClassByName(name):
74
print "No kafka package, please build it and add it into classpath:"
75
print " $ sbt/sbt streaming-kafka/package"
76
print " $ bin/submit --driver-class-path lib_managed/jars/kafka_2.10-0.8.0.jar:" \
77
- "external/kafka/target/scala-2.10/spark-streaming-kafka_2.10-1.3.0-SNAPSHOT.jar"
+ "external/kafka/target/scala-2.10/spark-streaming-kafka_2.10-1.3.0-SNAPSHOT.jar"
78
raise e
79
ser = PairDeserializer(NoOpSerializer(), NoOpSerializer())
80
stream = DStream(jstream, ssc, ser)
0 commit comments