What kafka receiver are you using? Did you build a new jar for your
app with the latest streaming-kafka code for 1.1?
On Thu, Sep 18, 2014 at 11:47 AM, JiajiaJing jj.jing0...@gmail.com wrote:
Hi Spark Users,
We just upgrade our spark version from 1.0 to 1.1. And we are trying to
re-run all
Yeah, I forgot to build the new jar file for spark 1.1...
And now the errors are gone.
Thank you very much!
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/Kafka-Spark-Streaming-on-Spark-1-1-tp14597p14604.html
Sent from the Apache Spark User List mailing
