Hi all,
I'm upgrading to the new version of storm and am running into some issues.
I'll start by providing some background information. I'm running storm from
some docker containers on an ec2 instance. I used this:
https://hub.docker.com/_/storm/ to set up my containers with storm. I then
made copies of my current topologies for an upgrade. I upgraded storm and
the hadoop dependencies in my pom.
The issue I am having is when I run my topology, I get the following error:
Exception in thread "main" java.lang.NoClassDefFoundError:
backtype/storm/tuple/Tuple
at java.lang.Class.getDeclaredMethods0(Native Method)
at java.lang.Class.privateGetDeclaredMethods(Class.java:2701)
at java.lang.Class.getDeclaredMethod(Class.java:2128)
at
java.io.ObjectStreamClass.getPrivateMethod(ObjectStreamClass.java:1629)
at java.io.ObjectStreamClass.access$1700(ObjectStreamClass.java:79)
at java.io.ObjectStreamClass$3.run(ObjectStreamClass.java:520)
at java.io.ObjectStreamClass$3.run(ObjectStreamClass.java:494)
at java.security.AccessController.doPrivileged(Native Method)
at java.io.ObjectStreamClass.<init>(ObjectStreamClass.java:494)
at java.io.ObjectStreamClass.lookup(ObjectStreamClass.java:391)
at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1134)
at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:348)
at org.apache.storm.utils.Utils.javaSerialize(Utils.java:520)
at
org.apache.storm.topology.TopologyBuilder.createTopology(TopologyBuilder.java:116)
at
summarizer2.storm.SummarizerTopology.main(SummarizerTopology.java:213)
Caused by: java.lang.ClassNotFoundException: backtype.storm.tuple.Tuple
at java.net.URLClassLoader.findClass(URLClassLoader.java:382)
at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:349)
at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
... 15 more
As part of the upgrade I went through my codebase and replace
backtype.* with org.apache.storm.*
It is odd to me that backtype is still referenced somehow. My
storm-client on my docker container is 2.0 and so is the one I package
from my pom. I am stumped as to why I get this error, however I am
convinced it has something to do with the storm-client jar on my
docker container. Any ideas?
Thanks,
--
Berges Irani
Engineering Intern
[email protected]
