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
