storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From <Samuel.Buch...@swisscom.com>
Subject Upgrade to 1.0.0, problem with Testing: java.lang.ClassNotFoundException: int
Date Wed, 20 Apr 2016 11:38:21 GMT
Hi everyone,
we are evaluating upgrading from Storm 0.10.0 to 1.0.0, but we get a strange error in our
tests (the actual application seems to run, but we have not extensively tested it yet). The
problem seems to occur within

Testing.completeTopology(cluster, ourTopology, completeTopologyParam);

called within

Testing.withSimulatedTimeLocalCluster(mkClusterParam, cluster -> { ... } );

in the usual manner (similar to https://github.com/xumingming/storm-lib/blob/master/src/jvm/storm/TestingApiDemo.java
). The error message is attached at the end of this mail. Has anyone seen this before and/or
could point us towards a solution of the problem?

On a side note, this error seems to kill the JVM, so that not only this particular, but also
all subsequent tests fail, which is very cumbersome. Is there any way to avoid this?

Thank you very much and with kind regards

Samuel

PS: Here is the error message:

2016-04-20 10:57:33,274 INFO  [Thread-215] tools.logging$eval1$fn__7 (NO_SOURCE_FILE:0) -
Loading executor filterBolt:[8 8]
2016-04-20 10:57:33,282 ERROR [Thread-215] tools.logging$eval1$fn__7 (NO_SOURCE_FILE:0) -
Error on initialization of server mk-worker
java.lang.RuntimeException: java.lang.ClassNotFoundException: int
                at org.apache.storm.utils.Utils.javaDeserialize(Utils.java:181)
                at org.apache.storm.utils.Utils.getSetComponentObject(Utils.java:430)
                at org.apache.storm.daemon.task$get_task_object.invoke(task.clj:74)
                at org.apache.storm.daemon.task$mk_task_data$fn__7593.invoke(task.clj:177)
                at org.apache.storm.util$assoc_apply_self.invoke(util.clj:930)
                at org.apache.storm.daemon.task$mk_task_data.invoke(task.clj:170)
                at org.apache.storm.daemon.task$mk_task.invoke(task.clj:181)
                at org.apache.storm.daemon.executor$mk_executor$fn__7812.invoke(executor.clj:371)
                at clojure.core$map$fn__4553.invoke(core.clj:2622)
                at clojure.lang.LazySeq.sval(LazySeq.java:40)
                at clojure.lang.LazySeq.seq(LazySeq.java:49)
                at clojure.lang.RT.seq(RT.java:507)
                at clojure.core$seq__4128.invoke(core.clj:137)
                at clojure.core.protocols$seq_reduce.invoke(protocols.clj:30)
                at clojure.core.protocols$fn__6506.invoke(protocols.clj:101)
                at clojure.core.protocols$fn__6452$G__6447__6465.invoke(protocols.clj:13)
                at clojure.core$reduce.invoke(core.clj:6519)
                at clojure.core$into.invoke(core.clj:6600)
                at org.apache.storm.daemon.executor$mk_executor.invoke(executor.clj:372)
                at org.apache.storm.daemon.worker$fn__8442$exec_fn__2453__auto__$reify__8444$iter__8449__8453$fn__8454.invoke(worker.clj:634)
                at clojure.lang.LazySeq.sval(LazySeq.java:40)
                at clojure.lang.LazySeq.seq(LazySeq.java:49)
                at clojure.lang.RT.seq(RT.java:507)
                at clojure.core$seq__4128.invoke(core.clj:137)
                at clojure.core$dorun.invoke(core.clj:3009)
                at clojure.core$doall.invoke(core.clj:3025)
                at org.apache.storm.daemon.worker$fn__8442$exec_fn__2453__auto__$reify__8444.run(worker.clj:634)
                at java.security.AccessController.doPrivileged(Native Method)
                at javax.security.auth.Subject.doAs(Subject.java:422)
                at org.apache.storm.daemon.worker$fn__8442$exec_fn__2453__auto____8443.invoke(worker.clj:606)
                at clojure.lang.AFn.applyToHelper(AFn.java:178)
                at clojure.lang.AFn.applyTo(AFn.java:144)
                at clojure.core$apply.invoke(core.clj:630)
                at org.apache.storm.daemon.worker$fn__8442$mk_worker__8537.doInvoke(worker.clj:580)
                at clojure.lang.RestFn.invoke(RestFn.java:512)
                at org.apache.storm.daemon.supervisor$fn__9357.invoke(supervisor.clj:1200)
                at clojure.lang.MultiFn.invoke(MultiFn.java:251)
                at org.apache.storm.daemon.supervisor$get_valid_new_worker_ids$iter__8918__8922$fn__8923.invoke(supervisor.clj:380)
                at clojure.lang.LazySeq.sval(LazySeq.java:40)
                at clojure.lang.LazySeq.seq(LazySeq.java:49)
                at clojure.lang.RT.seq(RT.java:507)
                at clojure.core$seq__4128.invoke(core.clj:137)
                at clojure.core$dorun.invoke(core.clj:3009)
                at clojure.core$doall.invoke(core.clj:3025)
                at org.apache.storm.daemon.supervisor$get_valid_new_worker_ids.invoke(supervisor.clj:367)
                at org.apache.storm.daemon.supervisor$sync_processes.invoke(supervisor.clj:428)
                at clojure.core$partial$fn__4527.invoke(core.clj:2492)
                at org.apache.storm.event$event_manager$fn__8622.invoke(event.clj:40)
                at clojure.lang.AFn.run(AFn.java:22)
                at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.ClassNotFoundException: int
                at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
                at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
                at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:331)
                at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
                at java.lang.Class.forName0(Native Method)
                at java.lang.Class.forName(Class.java:348)
                at org.apache.storm.shade.org.apache.commons.io.input.ClassLoaderObjectInputStream.resolveClass(ClassLoaderObjectInputStream.java:68)
                at java.io.ObjectInputStream.readNonProxyDesc(ObjectInputStream.java:1613)
                at java.io.ObjectInputStream.readClassDesc(ObjectInputStream.java:1518)
                at java.io.ObjectInputStream.readClass(ObjectInputStream.java:1484)
                at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1334)
                at java.io.ObjectInputStream.readArray(ObjectInputStream.java:1707)
                at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1345)
                at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000)
                at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924)
                at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801)
                at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
                at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000)
                at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924)
                at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801)
                at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
                at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000)
                at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924)
                at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801)
                at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
                at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000)
                at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924)
                at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801)
                at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
                at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000)
                at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924)
                at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801)
                at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
                at java.io.ObjectInputStream.readArray(ObjectInputStream.java:1707)
                at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1345)
                at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000)
                at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924)
                at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801)
                at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
                at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000)
                at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924)
                at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801)
                at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
                at java.io.ObjectInputStream.readObject(ObjectInputStream.java:371)
                at java.util.concurrent.ConcurrentHashMap.readObject(ConcurrentHashMap.java:1445)
                at sun.reflect.GeneratedMethodAccessor185.invoke(Unknown Source)
                at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
                at java.lang.reflect.Method.invoke(Method.java:497)
                at java.io.ObjectStreamClass.invokeReadObject(ObjectStreamClass.java:1017)
                at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1900)
                at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801)
                at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
                at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000)
                at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924)
                at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801)
                at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
                at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000)
                at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924)
                at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801)
                at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
                at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000)
                at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924)
                at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801)
                at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
                at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000)
                at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924)
                at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801)
                at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
                at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000)
                at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924)
                at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801)
                at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
                at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000)
                at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924)
                at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801)
                at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
                at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000)
                at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924)
                at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801)
                at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
                at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000)
                at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924)
                at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801)
                at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
                at java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2000)
                at java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:1924)
                at java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:1801)
                at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1351)
                at java.io.ObjectInputStream.readObject(ObjectInputStream.java:371)
                at org.apache.storm.utils.Utils.javaDeserialize(Utils.java:175)
                ... 49 more
2016-04-20 10:57:33,289 ERROR [Thread-215] tools.logging$eval1$fn__7 (NO_SOURCE_FILE:0) -
Halting process: ("Error on initialization")
java.lang.RuntimeException: ("Error on initialization")
                at org.apache.storm.util$exit_process_BANG_.doInvoke(util.clj:341)
                at clojure.lang.RestFn.invoke(RestFn.java:423)
                at org.apache.storm.daemon.worker$fn__8442$mk_worker__8537.doInvoke(worker.clj:580)
                at clojure.lang.RestFn.invoke(RestFn.java:512)
                at org.apache.storm.daemon.supervisor$fn__9357.invoke(supervisor.clj:1200)
                at clojure.lang.MultiFn.invoke(MultiFn.java:251)
                at org.apache.storm.daemon.supervisor$get_valid_new_worker_ids$iter__8918__8922$fn__8923.invoke(supervisor.clj:380)
                at clojure.lang.LazySeq.sval(LazySeq.java:40)
                at clojure.lang.LazySeq.seq(LazySeq.java:49)
                at clojure.lang.RT.seq(RT.java:507)
                at clojure.core$seq__4128.invoke(core.clj:137)
                at clojure.core$dorun.invoke(core.clj:3009)
                at clojure.core$doall.invoke(core.clj:3025)
                at org.apache.storm.daemon.supervisor$get_valid_new_worker_ids.invoke(supervisor.clj:367)
                at org.apache.storm.daemon.supervisor$sync_processes.invoke(supervisor.clj:428)
                at clojure.core$partial$fn__4527.invoke(core.clj:2492)
                at org.apache.storm.event$event_manager$fn__8622.invoke(event.clj:40)
                at clojure.lang.AFn.run(AFn.java:22)
                at java.lang.Thread.run(Thread.java:745)

Process finished with exit code 13








Mime
View raw message