I am using spark streaming. what i am trying to do is sending few messages
to some kafka topic. where its failing.
java.lang.ClassNotFoundException: com.abc.mq.msg.ObjectEncoder
at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:331)
at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
at java.lang.Class.forName0(Native Method)
at java.lang.Class.forName(Class.java:264)
at kafka.utils.Utils$.createObject(Utils.scala:438)
at kafka.producer.Producer.<init>(Producer.scala:61)
On Mon, Jun 22, 2015 at 8:24 PM, Murthy Chelankuri <kmurt...@gmail.com>
wrote:
> I have been using the spark from the last 6 months with the version 1.2.0.
>
> I am trying to migrate to the 1.3.0 but the same problem i have written is
> not wokring.
>
> Its giving class not found error when i try to load some dependent jars
> from the main program.
>
> This use to work in 1.2.0 when set all the dependent jars array to the
> spark context but not working in 1.3.0
>
>
> Please help me how to resolve this.
>
>
> Thanks,
> Murthy Chelankuri
>
