It was indeed a classpath/maven issue. Thank you Nathan!
On Mon, Mar 10, 2014 at 2:36 PM, Nathan Leung <[email protected]> wrote: > These appear to classes generated from clojure. Are you building against > the same version of storm that you are using to run the application? > > > On Mon, Mar 10, 2014 at 8:07 AM, James Hardy <[email protected]>wrote: > >> Hi >> >> I'm hoping someone can help. I've been learning Storm for the past few >> hours and everything has been great however I'm getting >> a java.lang.ClassNotFoundException: >> backtype.storm.daemon.nimbus$normalize_conf$get_merged_conf_val__3916$fn__3917 >> exception when trying to submit my topology to a local cluster. >> >> I have a simple spout which emits the string "go" and the ExclamationBolt >> taken from the examples. I wanted to create a pipeline of bolts and so >> created a topology: >> >> TopologyBuilder builder = new TopologyBuilder(); >> builder.setSpout("test", new Spout()); >> builder.setBolt("ex1", new ExclamationBolt()).shuffleGrouping("test"); >> builder.setBolt("ex2", new ExclamationBolt()).shuffleGrouping("ex1"); >> >> This works fine no problem at all however when I add another bolt I get >> the "Topology submission exception": >> >> TopologyBuilder builder = new TopologyBuilder(); >> builder.setSpout("test", new Spout()); >> builder.setBolt("ex1", new ExclamationBolt()).shuffleGrouping("test"); >> builder.setBolt("ex2", new ExclamationBolt()).shuffleGrouping("ex1"); >> builder.setBolt("ex3", new ExclamationBolt()).shuffleGrouping("ex2"); >> >> If anyone has any ideas they would be really appreciated. I feel like >> I've hit a brick wall :/ >> >> Thanks >> >> James >> > >
