Does your worker node also have the same storm version installed make sure your older STORM_HOME is not in PATH.
On Thu, Jul 17, 2014, at 06:39 PM, 唐思成 wrote: the step i took listed below 1. kill -9 all storm process 2. remove storm directory on zookeeper 3. change storm local dir 4. start nimbus and ui (is fine) 5. start supervisor on a worknode( the nimbus goes down) 2014-07-18 __________________________________________________________ 唐思成 __________________________________________________________ 发件人： Itai Frenkel 发送时间： 2014-07-18 00:16:21 收件人： storm_user 抄送： 主题： RE: storm upgrade issue The message says that SupervisorInfo that your code was compiled with is not compatible with the SupervisorInfo that was received over the network. That happens when you have a Serializable class that changes and there is no explicit backwards compatibility in place. I would first check that all of your Storm instances are running the same version. If that does not help I would check that you code is compiled against the correct code version. Please report your findings, since it's interesting :) full disclosure - I'm a Storm newbie, Itai __________________________________________________________ From: 唐思成 <[email protected]> Sent: Thursday, July 17, 2014 2:23 PM To: storm_user Subject: storm upgrade issue Hi all: I try to upgrade storm from 0.9.1 to 0.9.2-incubating, and when the worknode supervisor startup, the nimbus process goes down, here is what the nimbus.log say: Before upgrade, I already change storm.local.dir: to a new location and remove storm node in zookeeper using zkCli.sh, however that dont help. AnyIdea? 2014-07-17 19:15:29 b.s.d.nimbus [ERROR] Error when processing event java.lang.RuntimeException: java.io.InvalidClassException: back type.storm.daemon.common.SupervisorInfo; local class incompatib le: stream classdesc serialVersionUID = 7648414326720210054, lo cal class serialVersionUID = 7463898661547835557 at backtype.storm.utils.Utils.deserialize(Utils.java:93 ) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] at backtype.storm.cluster$maybe_deserialize.invoke(clus ter.clj:200) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating ] at backtype.storm.cluster$mk_storm_cluster_state$reify_ _2284.supervisor_info(cluster.clj:299) ~[storm-core-0.9.2-incub ating.jar:0.9.2-incubating] at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:na] at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMe thodAccessorImpl.java:39) ~[na:na] at sun.reflect.DelegatingMethodAccessorImpl.invoke(Dele gatingMethodAccessorImpl.java:25) ~[na:na] at java.lang.reflect.Method.invoke(Method.java:597) ~[n a:na] at clojure.lang.Reflector.invokeMatchingMethod(Reflecto r.java:93) ~[clojure-1.5.1.jar:na] at clojure.lang.Reflector.invokeInstanceMethod(Reflecto r.java:28) ~[clojure-1.5.1.jar:na] at backtype.storm.daemon.nimbus$all_supervisor_info$fn_ _4715.invoke(nimbus.clj:277) ~[storm-core-0.9.2-incubating.jar: 0.9.2-incubating] at clojure.core$map$fn__4207.invoke(core.clj:2487) ~[cl ojure-1.5.1.jar:na] at clojure.lang.LazySeq.sval(LazySeq.java:42) ~[clojure -1.5.1.jar:na] at clojure.lang.LazySeq.seq(LazySeq.java:60) ~[clojure- 1.5.1.jar:na] at clojure.lang.RT.seq(RT.java:484) ~[clojure-1.5.1.jar :na] at clojure.core$seq.invoke(core.clj:133) ~[clojure-1.5. 1.jar:na] at clojure.core$apply.invoke(core.clj:617) ~[clojure-1. 5.1.jar:na] at clojure.core$mapcat.doInvoke(core.clj:2514) ~[clojur e-1.5.1.jar:na] at clojure.lang.RestFn.invoke(RestFn.java:423) ~[clojur e-1.5.1.jar:na] at backtype.storm.daemon.nimbus$all_supervisor_info.inv oke(nimbus.clj:275) ~[storm-core-0.9.2-incubating.jar:0.9.2-inc ubating] at backtype.storm.daemon.nimbus$all_scheduling_slots.in voke(nimbus.clj:288) ~[storm-core-0.9.2-incubating.jar:0.9.2-in cubating] at backtype.storm.daemon.nimbus$compute_new_topology__G T_executor__GT_node_PLUS_port.invoke(nimbus.clj:580) ~[storm-co re-0.9.2-incubating.jar:0.9.2-incubating] at backtype.storm.daemon.nimbus$mk_assignments.doInvoke (nimbus.clj:660) ~[storm-core-0.9.2-incubating.jar:0.9.2-incuba ting] at clojure.lang.RestFn.invoke(RestFn.java:410) ~[clojur e-1.5.1.jar:na] at backtype.storm.daemon.nimbus$fn__5210$exec_fn__1396_ _auto____5211$fn__5216$fn__5217.invoke(nimbus.clj:905) ~[storm- core-0.9.2-incubating.jar:0.9.2-incubating] at backtype.storm.daemon.nimbus$fn__5210$exec_fn__1396_ _auto____5211$fn__5216.invoke(nimbus.clj:904) ~[storm-core-0.9. 2-incubating.jar:0.9.2-incubating] at backtype.storm.timer$schedule_recurring$this__1134.i nvoke(timer.clj:99) ~[storm-core-0.9.2-incubating.jar:0.9.2-inc ubating] at backtype.storm.timer$mk_timer$fn__1117$fn__1118.invo ke(timer.clj:50) ~[storm-core-0.9.2-incubating.jar:0.9.2-incuba ting] at backtype.storm.timer$mk_timer$fn__1117.invoke(timer. clj:42) [storm-core-0.9.2-incubating.jar:0.9.2-incubating] at clojure.lang.AFn.run(AFn.java:24) [clojure-1.5.1.jar :na] at java.lang.Thread.run(Thread.java:619) [na:na] Caused by: java.io.InvalidClassException: backtype.storm.daemon .common.SupervisorInfo; local class incompatible: stream classd esc serialVersionUID = 7648414326720210054, local class serialV ersionUID = 7463898661547835557 at java.io.ObjectStreamClass.initNonProxy(ObjectStreamC lass.java:562) ~[na:na] at java.io.ObjectInputStream.readNonProxyDesc(ObjectInp utStream.java:1583) ~[na:na] at java.io.ObjectInputStream.readClassDesc(ObjectInputS tream.java:1496) ~[na:na] at java.io.ObjectInputStream.readOrdinaryObject(ObjectI nputStream.java:1732) ~[na:na] at java.io.ObjectInputStream.readObject0(ObjectInputStr eam.java:1329) ~[na:na] at java.io.ObjectInputStream.readObject(ObjectInputStre am.java:351) ~[na:na] at backtype.storm.utils.Utils.deserialize(Utils.java:89 ) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating] ... 29 common frames omitted
