Hi,
I’m a developer using Storm in our production environment.
When running my topology locally, everything works fine.
However, when trying to run storm with my topology on a remote Nimbus server, I
get the following exception:
Exception in thread "main" java.lang.ExceptionInInitializerError
at
backtype.storm.topology.TopologyBuilder.createTopology(TopologyBuilder.java:106)
at com.jivesoftware.playbox.engine.Main.main(Main.java:77)
Caused by: java.lang.ClassCastException:
org.apache.storm.serialization.GzipThriftSerializationDelegate cannot be cast
to backtype.storm.serialization.SerializationDelegate
at backtype.storm.utils.Utils.getSerializationDelegate(Utils.java:432)
at backtype.storm.utils.Utils.<clinit>(Utils.java:72)
... 2 more
My server has Strom version 1.1.0 installed and my topology is using storm-core
0.9.4 version.
It seems that there’s a conflict between the versions,
GzipThriftSerializationDelegate from package org.apache.storm.serialization is
being cast to backtype.storm.serialization.SerializationDelegate instead of
being cast to
org.apache.storm.serialization.SerializationDelegate.
I would appreciate your help on that,
Thanks in advance,
Yovav