Hi, Its known issue with latest version of storm.
https://issues.apache.org/jira/browse/STORM-1773 On Thu, May 19, 2016 at 2:57 AM, Rama Nallamilli <[email protected]> wrote: > Hi there, > > I attempted an upgrade from Storm 0.10.0 -> 1.0.1, most of it went > smoothly up until the last hurdle of submitting the topology, we are trying > to submit to a Local Cluster in memory (our tests do this) but are get the > following serialization errors when running. > > We are using Scala 2.11 and build with sbt, the tests do work fine from > IntelliJ which is unusual. Java version for building topology is 1.8, > Scala version is 2_11. Works fine on Storm 0.10.0. > > Anybody else had this issue or could point to any possible causes? > > > 2016-05-18 16:18:42,587 ERROR org.apache.storm.daemon.worker - Error on > initialization of server mk-worker > java.lang.RuntimeException: java.io.InvalidClassException: > scala.collection.immutable.Map$Map1; local class incompatible: stream > classdesc serialVersionUID = -331641707862204208, local class > serialVersionUID = 6416318198292458305 > at org.apache.storm.utils.Utils.javaDeserialize(Utils.java:179) > ~[storm-core-1.0.1.jar:1.0.1] > at org.apache.storm.utils.Utils.getSetComponentObject(Utils.java:430) > ~[storm-core-1.0.1.jar:1.0.1] > at org.apache.storm.daemon.task$get_task_object.invoke(task.clj:74) > ~[storm-core-1.0.1.jar:1.0.1] > at org.apache.storm.daemon.task$mk_task_data$fn__7601.invoke(task.clj:177) > ~[storm-core-1.0.1.jar:1.0.1] > at org.apache.storm.util$assoc_apply_self.invoke(util.clj:930) > ~[storm-core-1.0.1.jar:1.0.1] > at org.apache.storm.daemon.task$mk_task_data.invoke(task.clj:170) > ~[storm-core-1.0.1.jar:1.0.1] > at org.apache.storm.daemon.task$mk_task.invoke(task.clj:181) > ~[storm-core-1.0.1.jar:1.0.1] > at > org.apache.storm.daemon.executor$mk_executor$fn__7820.invoke(executor.clj:371) > ~[storm-core-1.0.1.jar:1.0.1] > at clojure.core$map$fn__4553.invoke(core.clj:2622) ~[clojure-1.7.0.jar:na] > at clojure.lang.LazySeq.sval(LazySeq.java:40) [clojure-1.7.0.jar:na] > at clojure.lang.LazySeq.seq(LazySeq.java:49) [clojure-1.7.0.jar:na] > at clojure.lang.RT.seq(RT.java:507) [clojure-1.7.0.jar:na] > at clojure.core$seq__4128.invoke(core.clj:137) [clojure-1.7.0.jar:na] > at clojure.core.protocols$seq_reduce.invoke(protocols.clj:30) > ~[clojure-1.7.0.jar:na] > at clojure.core.protocols$fn__6506.invoke(protocols.clj:101) > ~[clojure-1.7.0.jar:na] > at clojure.core.protocols$fn__6452$G__6447__6465.invoke(protocols.clj:13) > ~[clojure-1.7.0.jar:na] > at clojure.core$reduce.invoke(core.clj:6519) ~[clojure-1.7.0.jar:na] > at clojure.core$into.invoke(core.clj:6600) ~[clojure-1.7.0.jar:na] > at org.apache.storm.daemon.executor$mk_executor.invoke(executor.clj:372) > ~[storm-core-1.0.1.jar:1.0.1] > at > org.apache.storm.daemon.worker$fn__8450$exec_fn__2461__auto__$reify__8452$iter__8457__8461$fn__8462.invoke(worker.clj:637) > ~[storm-core-1.0.1.jar:1.0.1] > at clojure.lang.LazySeq.sval(LazySeq.java:40) [clojure-1.7.0.jar:na] > at clojure.lang.LazySeq.seq(LazySeq.java:49) [clojure-1.7.0.jar:na] > at clojure.lang.RT.seq(RT.java:507) [clojure-1.7.0.jar:na] > at clojure.core$seq__4128.invoke(core.clj:137) [clojure-1.7.0.jar:na] > at clojure.core$dorun.invoke(core.clj:3009) [clojure-1.7.0.jar:na] > at clojure.core$doall.invoke(core.clj:3025) [clojure-1.7.0.jar:na] > at > org.apache.storm.daemon.worker$fn__8450$exec_fn__2461__auto__$reify__8452.run(worker.clj:637) > ~[storm-core-1.0.1.jar:1.0.1] > at java.security.AccessController.doPrivileged(Native Method) > ~[na:1.8.0_66] > at javax.security.auth.Subject.doAs(Subject.java:422) ~[na:1.8.0_66] > at > org.apache.storm.daemon.worker$fn__8450$exec_fn__2461__auto____8451.invoke(worker.clj:609) > ~[storm-core-1.0.1.jar:1.0.1] > at clojure.lang.AFn.applyToHelper(AFn.java:178) [clojure-1.7.0.jar:na] > at clojure.lang.AFn.applyTo(AFn.java:144) [clojure-1.7.0.jar:na] > at clojure.core$apply.invoke(core.clj:630) ~[clojure-1.7.0.jar:na] > at > org.apache.storm.daemon.worker$fn__8450$mk_worker__8545.doInvoke(worker.clj:583) > [storm-core-1.0.1.jar:1.0.1] > at clojure.lang.RestFn.invoke(RestFn.java:512) [clojure-1.7.0.jar:na] > at org.apache.storm.daemon.supervisor$fn__9365.invoke(supervisor.clj:1200) > [storm-core-1.0.1.jar:1.0.1] > at clojure.lang.MultiFn.invoke(MultiFn.java:251) [clojure-1.7.0.jar:na] > at > org.apache.storm.daemon.supervisor$get_valid_new_worker_ids$iter__8926__8930$fn__8931.invoke(supervisor.clj:380) > [storm-core-1.0.1.jar:1.0.1] > at clojure.lang.LazySeq.sval(LazySeq.java:40) [clojure-1.7.0.jar:na] > at clojure.lang.LazySeq.seq(LazySeq.java:49) [clojure-1.7.0.jar:na] > at clojure.lang.RT.seq(RT.java:507) [clojure-1.7.0.jar:na] > at clojure.core$seq__4128.invoke(core.clj:137) [clojure-1.7.0.jar:na] > at clojure.core$dorun.invoke(core.clj:3009) [clojure-1.7.0.jar:na] > at clojure.core$doall.invoke(core.clj:3025) [clojure-1.7.0.jar:na] > at > org.apache.storm.daemon.supervisor$get_valid_new_worker_ids.invoke(supervisor.clj:367) > [storm-core-1.0.1.jar:1.0.1] > at > org.apache.storm.daemon.supervisor$sync_processes.invoke(supervisor.clj:428) > [storm-core-1.0.1.jar:1.0.1] > at clojure.core$partial$fn__4527.invoke(core.clj:2492) > [clojure-1.7.0.jar:na] > at org.apache.storm.event$event_manager$fn__8630.invoke(event.clj:40) > [storm-core-1.0.1.jar:1.0.1] > at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:na] > at java.lang.Thread.run(Thread.java:745) [na:1.8.0_66] > Caused by: java.io.InvalidClassException: > scala.collection.immutable.Map$Map1; local class incompatible: stream > classdesc serialVersionUID = -331641707862204208, local class > serialVersionUID = 6416318198292458305 > at java.io.ObjectStreamClass.initNonProxy(ObjectStreamClass.java:616) > ~[na:1.8.0_66] > at java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1623) > ~[na:1.8.0_66] > at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1518) > ~[na:1.8.0_66] > at > java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1774) > ~[na:1.8.0_66] > at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) > ~[na:1.8.0_66] > at > java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000) > ~[na:1.8.0_66] > at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1891) > ~[na:1.8.0_66] > at > java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801) > ~[na:1.8.0_66] > at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351) > ~[na:1.8.0_66] > at java.io.ObjectInputStream.readObject(ObjectInputStream.java:371) > ~[na:1.8.0_66] > at org.apache.storm.utils.Utils.javaDeserialize(Utils.java:175) > ~[storm-core-1.0.1.jar:1.0.1] > ... 49 common frames omitted > > > Kind Regards > Rama > -- Thanks & Regards Rajasekhar
