Do u get the same error even in case you use SPARK_SUBMIT_OPTIONS to specify the jar file for the twitter instead of %dep ?
Regards, Sourav On Wed, Feb 24, 2016 at 9:20 PM, Vinayak Agrawal <vinayakagrawa...@gmail.com > wrote: > Hi All, > I am trying to run Zeppelin Streaming example from official zeppelin site. > > https://zeppelin.incubator.apache.org/docs/0.5.5-incubating/tutorial/tutorial.html > > Earlier I had problem with dependency of Twitterutil which i resolved with > help of you guys by adding %dep parameter in a cell. > %dep > z.reset() > z.addRepo("Spark Packages Repo").url(" > http://dl.bintray.com/spark-packages/maven";) > z.load("org.apache.spark:spark-streaming-twitter_2.10:jar:1.6.0") > > However now I am facing a problem while querying the temp table tweets > which is created in the code. > Please see the error below: > Query : > %sql select createdAt, count(1) from tweets group by createdAt order by > createdAt > > Error: > org.apache.spark.SparkException: Job aborted due to stage failure: Task 0 > in stage 4.0 failed 4 times, most recent failure: Lost task 0.3 in stage > 4.0 (TID 80, sandbox.hortonworks.com): java.io.InvalidClassException: > twitter4j.Status; local class incompatible: stream classdesc > serialVersionUID = 4228152091240188172, local class serialVersionUID = > 2666552784741770311 at > java.io.ObjectStreamClass.initNonProxy(ObjectStreamClass.java:612) > at java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1622) > at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1517) at > java.io.ObjectInputStream.readClass(ObjectInputStream.java:1483) at > java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1333) at > java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:1997) at > java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1921) > > -- > Vinayak Agrawal > > > "To Strive, To Seek, To Find and Not to Yield!" > ~Lord Alfred Tennyson >
