May be You just replace a storm-core.jar. You need keep nimbus and supervisor at same one .
发送自我的 BlackBerry 10 智能手机。 发件人： Xing Yong 已发送： 2014年6月13日星期五 12:43 收件人： [email protected] 答复： [email protected] 主题： storm upgrade topology error i upgrade the storm cluster to 0.9.2-incubating, and submit a topology always appear the following error, any idea to share? thanks! 2014-06-13 12:35:05 b.s.d.worker [ERROR] Error on initialization of server mk-worker java.lang.RuntimeException: java.io.InvalidClassException: org.apache.commons.logging.impl.Log4JLogger; local class incompatible: stream classdesc serialVersionUID = 2930996631104246328, local class serialVersionUID = 5160705895411730424 at backtype.storm.utils.Utils.deserialize(Utils.java:93) ~[storm-core-0.9.2-incubating-mdh1.0-SNAPSHOT.jar:0.9.2-incubating-mdh1.0-SNAPSHOT] at backtype.storm.utils.Utils.getSetComponentObject(Utils.java:235) ~[storm-core-0.9.2-incubating-mdh1.0-SNAPSHOT.jar:0.9.2-incubating-mdh1.0-SNAPSHOT] at backtype.storm.daemon.task$get_task_object.invoke(task.clj:73) ~[storm-core-0.9.2-incubating-mdh1.0-SNAPSHOT.jar:0.9.2-incubating-mdh1.0-SNAPSHOT] at backtype.storm.daemon.task$mk_task_data$fn__3044.invoke(task.clj:180) ~[storm-core-0.9.2-incubating-mdh1.0-SNAPSHOT.jar:0.9.2-incubating-mdh1.0-SNAPSHOT] at backtype.storm.util$assoc_apply_self.invoke(util.clj:796) ~[storm-core-0.9.2-incubating-mdh1.0-SNAPSHOT.jar:0.9.2-incubating-mdh1.0-SNAPSHOT] at backtype.storm.daemon.task$mk_task_data.invoke(task.clj:173) ~[storm-core-0.9.2-incubating-mdh1.0-SNAPSHOT.jar:0.9.2-incubating-mdh1.0-SNAPSHOT] at backtype.storm.daemon.task$mk_task.invoke(task.clj:184) ~[storm-core-0.9.2-incubating-mdh1.0-SNAPSHOT.jar:0.9.2-incubating-mdh1.0-SNAPSHOT] at backtype.storm.daemon.executor$mk_executor$fn__3223.invoke(executor.clj:321) ~[storm-core-0.9.2-incubating-mdh1.0-SNAPSHOT.jar:0.9.2-incubating-mdh1.0-SNAPSHOT] at clojure.core$map$fn__4207.invoke(core.clj:2485) ~[clojure-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.protocols$seq_reduce.invoke(protocols.clj:30) ~[clojure-1.5.1.jar:na] at clojure.core.protocols$fn__6026.invoke(protocols.clj:54) ~[clojure-1.5.1.jar:na] at clojure.core.protocols$fn__5979$G__5974__5992.invoke(protocols.clj:13) ~[clojure-1.5.1.jar:na] at clojure.core$reduce.invoke(core.clj:6177) ~[clojure-1.5.1.jar:na] at clojure.core$into.invoke(core.clj:6229) ~[clojure-1.5.1.jar:na] at backtype.storm.daemon.executor$mk_executor.invoke(executor.clj:321) ~[storm-core-0.9.2-incubating-mdh1.0-SNAPSHOT.jar:0.9.2-incubating-mdh1.0-SNAPSHOT] at backtype.storm.daemon.worker$fn__3653$exec_fn__1690__auto____3654$iter__3659__3663$fn__3664.invoke(worker.clj:375) ~[storm-core-0.9.2-incubating-mdh1.0-SNAPSHOT.jar:0.9.2-incubating-mdh1.0-SNAPSHOT] 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.Cons.next(Cons.java:39) ~[clojure-1.5.1.jar:na] at clojure.lang.LazySeq.next(LazySeq.java:92) ~[clojure-1.5.1.jar:na] at clojure.lang.RT.next(RT.java:598) ~[clojure-1.5.1.jar:na] at clojure.core$next.invoke(core.clj:64) ~[clojure-1.5.1.jar:na] at clojure.core$dorun.invoke(core.clj:2781) ~[clojure-1.5.1.jar:na] at clojure.core$doall.invoke(core.clj:2796) ~[clojure-1.5.1.jar:na] at backtype.storm.daemon.worker$fn__3653$exec_fn__1690__auto____3654.invoke(worker.clj:375) ~[storm-core-0.9.2-incubating-mdh1.0-SNAPSHOT.jar:0.9.2-incubating-mdh1.0-SNAPSHOT] at clojure.lang.AFn.applyToHelper(AFn.java:185) [clojure-1.5.1.jar:na] at clojure.lang.AFn.applyTo(AFn.java:151) [clojure-1.5.1.jar:na] at clojure.core$apply.invoke(core.clj:617) ~[clojure-1.5.1.jar:na] at backtype.storm.daemon.worker$fn__3653$mk_worker__3709.doInvoke(worker.clj:347) [storm-core-0.9.2-incubating-mdh1.0-SNAPSHOT.jar:0.9.2-incubating-mdh1.0-SNAPSHOT] at clojure.lang.RestFn.invoke(RestFn.java:512) [clojure-1.5.1.jar:na] at backtype.storm.daemon.worker$_main.invoke(worker.clj:454) [storm-core-0.9.2-incubating-mdh1.0-SNAPSHOT.jar:0.9.2-incubating-mdh1.0-SNAPSHOT] at clojure.lang.AFn.applyToHelper(AFn.java:172) [clojure-1.5.1.jar:na] at clojure.lang.AFn.applyTo(AFn.java:151) [clojure-1.5.1.jar:na] at backtype.storm.daemon.worker.main(Unknown Source) [storm-core-0.9.2-incubating-mdh1.0-SNAPSHOT.jar:0.9.2-incubating-mdh1.0-SNAPSHOT] Caused by: java.io.InvalidClassException: org.apache.commons.logging.impl.Log4JLogger; local class incompatible: stream classdesc serialVersionUID = 2930996631104246328, local class serialVersionUID = 5160705895411730424
